org.apache.flink.streaming.connectors.elasticsearch.table

Class ElasticsearchOptions

java.lang.Object

org.apache.flink.streaming.connectors.elasticsearch.table.ElasticsearchOptions

public class ElasticsearchOptions
extends Object

Options for DynamicTableSinkFactory for Elasticsearch.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ElasticsearchOptions.BackOffType Backoff strategy.

Field Summary

Fields

Modifier and Type	Field and Description
static ConfigOption<MemorySize>	BULK_FLASH_MAX_SIZE_OPTION
static ConfigOption<java.time.Duration>	BULK_FLUSH_BACKOFF_DELAY_OPTION
static ConfigOption<Integer>	BULK_FLUSH_BACKOFF_MAX_RETRIES_OPTION
static ConfigOption<ElasticsearchOptions.BackOffType>	BULK_FLUSH_BACKOFF_TYPE_OPTION
static ConfigOption<java.time.Duration>	BULK_FLUSH_INTERVAL_OPTION
static ConfigOption<Integer>	BULK_FLUSH_MAX_ACTIONS_OPTION
static ConfigOption<java.time.Duration>	CONNECTION_MAX_RETRY_TIMEOUT_OPTION
static ConfigOption<String>	CONNECTION_PATH_PREFIX
static ConfigOption<String>	DOCUMENT_TYPE_OPTION
static ConfigOption<String>	FAILURE_HANDLER_OPTION
static ConfigOption<Boolean>	FLUSH_ON_CHECKPOINT_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<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

DOCUMENT_TYPE_OPTION

public static final ConfigOption<String> DOCUMENT_TYPE_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

FAILURE_HANDLER_OPTION

public static final ConfigOption<String> FAILURE_HANDLER_OPTION

FLUSH_ON_CHECKPOINT_OPTION

public static final ConfigOption<Boolean> FLUSH_ON_CHECKPOINT_OPTION

BULK_FLUSH_MAX_ACTIONS_OPTION

public static final ConfigOption<Integer> BULK_FLUSH_MAX_ACTIONS_OPTION

BULK_FLASH_MAX_SIZE_OPTION

public static final ConfigOption<MemorySize> BULK_FLASH_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<ElasticsearchOptions.BackOffType> 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_MAX_RETRY_TIMEOUT_OPTION

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

CONNECTION_PATH_PREFIX

public static final ConfigOption<String> CONNECTION_PATH_PREFIX

FORMAT_OPTION

public static final ConfigOption<String> FORMAT_OPTION