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 and 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 and 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()