java.lang.Object
- org.apache.flink.cdc.connectors.elasticsearch.sink.ElasticsearchDataSinkOptions

public class ElasticsearchDataSinkOptions
extends Object

Options for the Elasticsearch data sink.

Field Summary

Fields
Modifier and Type	Field	Description
`static ConfigOption<String>`	`HOSTS`	The comma-separated list of Elasticsearch hosts to connect to.
`static ConfigOption<Integer>`	`MAX_BATCH_SIZE`	The maximum number of actions to buffer for each bulk request.
`static ConfigOption<Long>`	`MAX_BATCH_SIZE_IN_BYTES`	The maximum size of batch requests in bytes.
`static ConfigOption<Integer>`	`MAX_BUFFERED_REQUESTS`	The maximum number of requests to keep in the in-memory buffer.
`static ConfigOption<Integer>`	`MAX_IN_FLIGHT_REQUESTS`	The maximum number of concurrent requests that the sink will try to execute.
`static ConfigOption<Long>`	`MAX_RECORD_SIZE_IN_BYTES`	The maximum size of a single record in bytes.
`static ConfigOption<Long>`	`MAX_TIME_IN_BUFFER_MS`	The maximum time to wait for incomplete batches before flushing.
`static ConfigOption<String>`	`PASSWORD`	The password for Elasticsearch authentication.
`static ConfigOption<String>`	`SHARDING_SUFFIX_KEY`	The sharding for Elasticsearch index, default sink table name is test_table_${suffix}.
`static ConfigOption<String>`	`SHARDING_SUFFIX_SEPARATOR`	The sharding for Elasticsearch index, default sink table name is test_table_${suffix}.
`static ConfigOption<String>`	`USERNAME`	The username for Elasticsearch authentication.
`static ConfigOption<Integer>`	`VERSION`	The version of Elasticsearch to connect to.

Method Summary
- Methods inherited from class java.lang.Object
  clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - HOSTS
```
public static final ConfigOption<String> HOSTS
```
    The comma-separated list of Elasticsearch hosts to connect to.
  - MAX_BATCH_SIZE
```
public static final ConfigOption<Integer> MAX_BATCH_SIZE
```
    The maximum number of actions to buffer for each bulk request.
  - MAX_IN_FLIGHT_REQUESTS
```
public static final ConfigOption<Integer> MAX_IN_FLIGHT_REQUESTS
```
    The maximum number of concurrent requests that the sink will try to execute.
  - MAX_BUFFERED_REQUESTS
```
public static final ConfigOption<Integer> MAX_BUFFERED_REQUESTS
```
    The maximum number of requests to keep in the in-memory buffer.
  - MAX_BATCH_SIZE_IN_BYTES
```
public static final ConfigOption<Long> MAX_BATCH_SIZE_IN_BYTES
```
    The maximum size of batch requests in bytes.
  - MAX_TIME_IN_BUFFER_MS
```
public static final ConfigOption<Long> MAX_TIME_IN_BUFFER_MS
```
    The maximum time to wait for incomplete batches before flushing.
  - MAX_RECORD_SIZE_IN_BYTES
```
public static final ConfigOption<Long> MAX_RECORD_SIZE_IN_BYTES
```
    The maximum size of a single record in bytes.
  - VERSION
```
public static final ConfigOption<Integer> VERSION
```
    The version of Elasticsearch to connect to.
  - USERNAME
```
public static final ConfigOption<String> USERNAME
```
    The username for Elasticsearch authentication.
  - PASSWORD
```
public static final ConfigOption<String> PASSWORD
```
    The password for Elasticsearch authentication.
  - SHARDING_SUFFIX_KEY
```
public static final ConfigOption<String> SHARDING_SUFFIX_KEY
```
    The sharding for Elasticsearch index, default sink table name is test_table_${suffix}.
  - SHARDING_SUFFIX_SEPARATOR
```
public static final ConfigOption<String> SHARDING_SUFFIX_SEPARATOR
```
    The sharding for Elasticsearch index, default sink table name is test_table_${suffix}.

Class ElasticsearchDataSinkOptions

Field Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

HOSTS

MAX_BATCH_SIZE

MAX_IN_FLIGHT_REQUESTS

MAX_BUFFERED_REQUESTS

MAX_BATCH_SIZE_IN_BYTES

MAX_TIME_IN_BUFFER_MS

MAX_RECORD_SIZE_IN_BYTES

VERSION

USERNAME

PASSWORD

SHARDING_SUFFIX_KEY

SHARDING_SUFFIX_SEPARATOR