org.apache.flink.connector.elasticsearch.table

Class ElasticsearchConnectorOptions

java.lang.Object

org.apache.flink.connector.elasticsearch.table.ElasticsearchConnectorOptions

Direct Known Subclasses:

Elasticsearch6ConnectorOptions

@PublicEvolving
public class ElasticsearchConnectorOptions
extends Object

Base options for the Elasticsearch connector. Needs to be public so that the TableDescriptor can access it.

Field Summary

Fields

Modifier and Type	Field and Description
static ConfigOption<java.time.Duration>	BULK_FLUSH_BACKOFF_DELAY_OPTION
static ConfigOption<Integer>	BULK_FLUSH_BACKOFF_MAX_RETRIES_OPTION
static ConfigOption<FlushBackoffType>	BULK_FLUSH_BACKOFF_TYPE_OPTION
static ConfigOption<java.time.Duration>	BULK_FLUSH_INTERVAL_OPTION
static ConfigOption<Integer>	BULK_FLUSH_MAX_ACTIONS_OPTION
static ConfigOption<MemorySize>	BULK_FLUSH_MAX_SIZE_OPTION
static ConfigOption<String>	CONNECTION_PATH_PREFIX_OPTION
static ConfigOption<java.time.Duration>	CONNECTION_REQUEST_TIMEOUT
static ConfigOption<java.time.Duration>	CONNECTION_TIMEOUT
static ConfigOption<DeliveryGuarantee>	DELIVERY_GUARANTEE_OPTION
static ConfigOption<String>	FORMAT_OPTION
static ConfigOption<List<String>>	HOSTS_OPTION
static ConfigOption<String>	INDEX_OPTION
static ConfigOption<String>	KEY_DELIMITER_OPTION
static ConfigOption<String>	PASSWORD_OPTION
static ConfigOption<java.time.Duration>	SOCKET_TIMEOUT
static ConfigOption<String>	USERNAME_OPTION

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

HOSTS_OPTION

public static final ConfigOption<List<String>> HOSTS_OPTION

INDEX_OPTION

public static final ConfigOption<String> INDEX_OPTION

PASSWORD_OPTION

public static final ConfigOption<String> PASSWORD_OPTION

USERNAME_OPTION

public static final ConfigOption<String> USERNAME_OPTION

KEY_DELIMITER_OPTION

public static final ConfigOption<String> KEY_DELIMITER_OPTION

BULK_FLUSH_MAX_ACTIONS_OPTION

public static final ConfigOption<Integer> BULK_FLUSH_MAX_ACTIONS_OPTION

BULK_FLUSH_MAX_SIZE_OPTION

public static final ConfigOption<MemorySize> BULK_FLUSH_MAX_SIZE_OPTION

BULK_FLUSH_INTERVAL_OPTION

public static final ConfigOption<java.time.Duration> BULK_FLUSH_INTERVAL_OPTION

BULK_FLUSH_BACKOFF_TYPE_OPTION

public static final ConfigOption<FlushBackoffType> BULK_FLUSH_BACKOFF_TYPE_OPTION

BULK_FLUSH_BACKOFF_MAX_RETRIES_OPTION

public static final ConfigOption<Integer> BULK_FLUSH_BACKOFF_MAX_RETRIES_OPTION

BULK_FLUSH_BACKOFF_DELAY_OPTION

public static final ConfigOption<java.time.Duration> BULK_FLUSH_BACKOFF_DELAY_OPTION

CONNECTION_PATH_PREFIX_OPTION

public static final ConfigOption<String> CONNECTION_PATH_PREFIX_OPTION

CONNECTION_REQUEST_TIMEOUT

public static final ConfigOption<java.time.Duration> CONNECTION_REQUEST_TIMEOUT

CONNECTION_TIMEOUT

public static final ConfigOption<java.time.Duration> CONNECTION_TIMEOUT

SOCKET_TIMEOUT

public static final ConfigOption<java.time.Duration> SOCKET_TIMEOUT

FORMAT_OPTION

public static final ConfigOption<String> FORMAT_OPTION

DELIVERY_GUARANTEE_OPTION

public static final ConfigOption<DeliveryGuarantee> DELIVERY_GUARANTEE_OPTION