Package org.apache.flink.connector.base.sink.writer.config

Class AsyncSinkWriterConfiguration

java.lang.Object

org.apache.flink.connector.base.sink.writer.config.AsyncSinkWriterConfiguration

@PublicEvolving
public class AsyncSinkWriterConfiguration
extends Object

AsyncSinkWriterConfiguration to configure the AsyncSinkWriter.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AsyncSinkWriterConfiguration.AsyncSinkWriterConfigurationBuilder	Builder for AsyncSinkWriterConfiguration.
static interface	AsyncSinkWriterConfiguration.ConfigurationMaxBatchSize	Required MaxBatchSize parameter for AsyncSinkWriterConfiguration.
static interface	AsyncSinkWriterConfiguration.ConfigurationMaxBatchSizeInBytes	Required MaxBatchSizeInBytes parameter for AsyncSinkWriterConfiguration.
static interface	AsyncSinkWriterConfiguration.ConfigurationMaxBufferedRequests	Required MaxBufferedRequests parameter for AsyncSinkWriterConfiguration.
static interface	AsyncSinkWriterConfiguration.ConfigurationMaxInFlightRequests	Required MaxInFlightRequests parameter for AsyncSinkWriterConfiguration.
static interface	AsyncSinkWriterConfiguration.ConfigurationMaxRecordSizeInBytes	Required MaxRecordSizeInBytes parameter for AsyncSinkWriterConfiguration.
static interface	AsyncSinkWriterConfiguration.ConfigurationMaxTimeInBufferMS	Required MaxTimeInBufferMS parameter for AsyncSinkWriterConfiguration.

Method Summary

Modifier and Type	Method	Description
static AsyncSinkWriterConfiguration.ConfigurationMaxBatchSize	builder()
int	getMaxBatchSize()
long	getMaxBatchSizeInBytes()
int	getMaxBufferedRequests()
int	getMaxInFlightRequests()
long	getMaxRecordSizeInBytes()
long	getMaxTimeInBufferMS()
RateLimitingStrategy	getRateLimitingStrategy()

Methods inherited from class java.lang.Object

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

Method Detail

getMaxBatchSize

public int getMaxBatchSize()

getMaxInFlightRequests

public int getMaxInFlightRequests()

getMaxBufferedRequests

public int getMaxBufferedRequests()

getMaxBatchSizeInBytes

public long getMaxBatchSizeInBytes()

getMaxTimeInBufferMS

public long getMaxTimeInBufferMS()

getMaxRecordSizeInBytes

public long getMaxRecordSizeInBytes()

getRateLimitingStrategy

public RateLimitingStrategy getRateLimitingStrategy()

builder

@PublicEvolving
public static AsyncSinkWriterConfiguration.ConfigurationMaxBatchSize builder()