Package com.google.cloud.bigquery

Class BigQueryRetryAlgorithm<ResponseT>

java.lang.Object

com.google.api.gax.retrying.RetryAlgorithm<ResponseT>

com.google.cloud.bigquery.BigQueryRetryAlgorithm<ResponseT>

public class BigQueryRetryAlgorithm<ResponseT>
extends RetryAlgorithm<ResponseT>

Constructor Summary

Constructors

Constructor	Description
BigQueryRetryAlgorithm(ResultRetryAlgorithm<ResponseT> resultAlgorithm, TimedRetryAlgorithm timedAlgorithm, BigQueryRetryConfig bigQueryRetryConfig)

Method Summary

Modifier and Type	Method	Description
TimedAttemptSettings	createNextAttempt(RetryingContext context, Throwable previousThrowable, ResponseT previousResponse, TimedAttemptSettings previousSettings)
static boolean	matchRegEx(String retriableRegEx, String errorDesc)
boolean	shouldRetry(RetryingContext context, Throwable previousThrowable, ResponseT previousResponse, TimedAttemptSettings nextAttemptSettings)

Methods inherited from class com.google.api.gax.retrying.RetryAlgorithm

createFirstAttempt, createFirstAttempt, createNextAttempt, getResultAlgorithm, getTimedAlgorithm, shouldRetry

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

BigQueryRetryAlgorithm

public BigQueryRetryAlgorithm(ResultRetryAlgorithm<ResponseT> resultAlgorithm,
 TimedRetryAlgorithm timedAlgorithm,
 BigQueryRetryConfig bigQueryRetryConfig)

Method Details

shouldRetry

public boolean shouldRetry(RetryingContext context,
 Throwable previousThrowable,
 ResponseT previousResponse,
 TimedAttemptSettings nextAttemptSettings)
                    throws CancellationException

Overrides:

shouldRetry in class RetryAlgorithm<ResponseT>

Throws:

CancellationException

matchRegEx

public static boolean matchRegEx(String retriableRegEx,
 String errorDesc)

createNextAttempt

public TimedAttemptSettings createNextAttempt(RetryingContext context,
 Throwable previousThrowable,
 ResponseT previousResponse,
 TimedAttemptSettings previousSettings)

Overrides:

createNextAttempt in class RetryAlgorithm<ResponseT>