org.apache.spark.sql.connect.client.RetryPolicy
See theRetryPolicy companion object
case class RetryPolicy(maxRetries: Option[Int], initialBackoff: FiniteDuration, maxBackoff: Option[FiniteDuration], backoffMultiplier: Double, jitter: FiniteDuration, minJitterThreshold: FiniteDuration, canRetry: Throwable => Boolean, name: String, recognizeServerRetryDelay: Boolean, maxServerRetryDelay: Option[FiniteDuration])
Configures the retry mechanism used by GrpcRetryHandler. Ported from Apache Spark's org.apache.spark.sql.connect.client.RetryPolicy.
Value parameters
- backoffMultiplier
-
multiplicative base of the exponential backoff.
- canRetry
-
predicate deciding whether an error is retryable.
- initialBackoff
-
start of the exponential backoff.
- jitter
-
random value in
[0, jitter]added to the backoff. - maxBackoff
-
cap on the exponential backoff.
- maxRetries
-
maximum number of retries (None = unbounded).
- maxServerRetryDelay
-
cap on the server-provided retry delay.
- minJitterThreshold
-
minimum backoff at which jitter is added.
- name
-
policy name (for diagnostics).
- recognizeServerRetryDelay
-
honor a server-provided
RetryInfo.retry_delay.
Attributes
- Companion
- object
- Graph
-
- Supertypes
-
trait Serializabletrait Producttrait Equalsclass Objecttrait Matchableclass Any
Members list
In this article