org.apache.flink.streaming.connectors.elasticsearch

Class ElasticsearchSinkBase.BulkFlushBackoffPolicy

java.lang.Object

org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.BulkFlushBackoffPolicy

All Implemented Interfaces:

Serializable

Enclosing class:

ElasticsearchSinkBase<T,C extends AutoCloseable>

public static class ElasticsearchSinkBase.BulkFlushBackoffPolicy
extends Object
implements Serializable

Provides a backoff policy for bulk requests. Whenever a bulk request is rejected due to resource constraints (i.e. the client's internal thread pool is full), the backoff policy decides how long the bulk processor will wait before the operation is retried internally.

This is a proxy for version specific backoff policies.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
BulkFlushBackoffPolicy()

Method Summary

Modifier and Type	Method and Description
ElasticsearchSinkBase.FlushBackoffType	getBackoffType()
long	getDelayMillis()
int	getMaxRetryCount()
void	setBackoffType(ElasticsearchSinkBase.FlushBackoffType backoffType)
void	setDelayMillis(long delayMillis)
void	setMaxRetryCount(int maxRetryCount)

Methods inherited from class java.lang.Object

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

Constructor Detail

BulkFlushBackoffPolicy

public BulkFlushBackoffPolicy()

Method Detail

getBackoffType

public ElasticsearchSinkBase.FlushBackoffType getBackoffType()

getMaxRetryCount

public int getMaxRetryCount()

getDelayMillis

public long getDelayMillis()

setBackoffType

public void setBackoffType(ElasticsearchSinkBase.FlushBackoffType backoffType)

setMaxRetryCount

public void setMaxRetryCount(int maxRetryCount)

setDelayMillis

public void setDelayMillis(long delayMillis)