Class AsyncSinkWriterConfiguration
- java.lang.Object
-
- org.apache.flink.connector.base.sink.writer.config.AsyncSinkWriterConfiguration
-
@PublicEvolving public class AsyncSinkWriterConfiguration extends Object
AsyncSinkWriterConfiguration
to configure theAsyncSinkWriter
.
-
-
Nested Class Summary
-
Field Summary
Fields Modifier and Type Field Description static boolean
DEFAULT_FAIL_ON_TIMEOUT
static long
DEFAULT_REQUEST_TIMEOUT_MS
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static AsyncSinkWriterConfiguration.ConfigurationMaxBatchSize
builder()
int
getMaxBatchSize()
long
getMaxBatchSizeInBytes()
int
getMaxBufferedRequests()
int
getMaxInFlightRequests()
long
getMaxRecordSizeInBytes()
long
getMaxTimeInBufferMS()
RateLimitingStrategy
getRateLimitingStrategy()
long
getRequestTimeoutMS()
boolean
isFailOnTimeout()
-
-
-
Field Detail
-
DEFAULT_REQUEST_TIMEOUT_MS
public static final long DEFAULT_REQUEST_TIMEOUT_MS
-
DEFAULT_FAIL_ON_TIMEOUT
public static final boolean DEFAULT_FAIL_ON_TIMEOUT
- See Also:
- Constant Field Values
-
-
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()
-
getRequestTimeoutMS
public long getRequestTimeoutMS()
-
isFailOnTimeout
public boolean isFailOnTimeout()
-
builder
@PublicEvolving public static AsyncSinkWriterConfiguration.ConfigurationMaxBatchSize builder()
-
-