Package org.apache.beam.sdk.io.elasticsearch

Class ElasticsearchIO.RetryConfiguration

java.lang.Object

org.apache.beam.sdk.io.elasticsearch.ElasticsearchIO.RetryConfiguration

All Implemented Interfaces:

Serializable

Enclosing class:

ElasticsearchIO

public abstract static class ElasticsearchIO.RetryConfiguration
extends Object
implements Serializable

A POJO encapsulating a configuration for retry behavior when issuing requests to ES. A retry will be attempted until the maxAttempts or maxDuration is exceeded, whichever comes first, for 429 TOO_MANY_REQUESTS error.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
RetryConfiguration()

Method Summary

Modifier and Type	Method	Description
static ElasticsearchIO.RetryConfiguration	create(int maxAttempts, Duration maxDuration)	Creates RetryConfiguration for ElasticsearchIO with provided maxAttempts, maxDurations and exponential backoff based retries.

Methods inherited from class java.lang.Object

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

Constructor Details

RetryConfiguration

public RetryConfiguration()

Method Details

create

public static ElasticsearchIO.RetryConfiguration create(int maxAttempts,
 Duration maxDuration)

Creates RetryConfiguration for ElasticsearchIO with provided maxAttempts, maxDurations and exponential backoff based retries.

Parameters:

maxAttempts - max number of attempts.

maxDuration - maximum duration for retries.

Returns:

ElasticsearchIO.RetryConfiguration object with provided settings.