Package org.apache.flink.connector.base.table

Class AsyncSinkConnectorOptions

java.lang.Object

org.apache.flink.connector.base.table.AsyncSinkConnectorOptions

@PublicEvolving
public class AsyncSinkConnectorOptions
extends Object

Optional Options for AsyncDynamicTableSinkFactory representing fields of AsyncSinkBase.

Field Summary

Fields

Modifier and Type	Field	Description
static ConfigOption<Long>	FLUSH_BUFFER_SIZE
static ConfigOption<Long>	FLUSH_BUFFER_TIMEOUT
static ConfigOption<Integer>	MAX_BATCH_SIZE
static ConfigOption<Integer>	MAX_BUFFERED_REQUESTS
static ConfigOption<Integer>	MAX_IN_FLIGHT_REQUESTS

Constructor Summary

Constructors

Constructor	Description
AsyncSinkConnectorOptions()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

MAX_BATCH_SIZE

public static final ConfigOption<Integer> MAX_BATCH_SIZE

MAX_IN_FLIGHT_REQUESTS

public static final ConfigOption<Integer> MAX_IN_FLIGHT_REQUESTS

MAX_BUFFERED_REQUESTS

public static final ConfigOption<Integer> MAX_BUFFERED_REQUESTS

FLUSH_BUFFER_SIZE

public static final ConfigOption<Long> FLUSH_BUFFER_SIZE

FLUSH_BUFFER_TIMEOUT

public static final ConfigOption<Long> FLUSH_BUFFER_TIMEOUT

Constructor Detail

AsyncSinkConnectorOptions

public AsyncSinkConnectorOptions()