Package org.apache.flink.cdc.connectors.elasticsearch.config

Class ElasticsearchSinkOptions

java.lang.Object

org.apache.flink.cdc.connectors.elasticsearch.config.ElasticsearchSinkOptions

All Implemented Interfaces:

Serializable

public class ElasticsearchSinkOptions
extends Object
implements Serializable

Elasticsearch DataSink Options reference ElasticsearchSinkOptions.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
ElasticsearchSinkOptions(int maxBatchSize, int maxInFlightRequests, int maxBufferedRequests, long maxBatchSizeInBytes, long maxTimeInBufferMS, long maxRecordSizeInBytes, NetworkConfig networkConfig, int version, String username, String password)	Constructor for ElasticsearchSinkOptions.
ElasticsearchSinkOptions(int maxBatchSize, int maxInFlightRequests, int maxBufferedRequests, long maxBatchSizeInBytes, long maxTimeInBufferMS, long maxRecordSizeInBytes, NetworkConfig networkConfig, int version, String username, String password, Map<TableId,String> shardingKey, String shardingSeparator)

Method Summary

Modifier and Type	Method	Description
List<org.apache.http.HttpHost>	getHosts()
int	getMaxBatchSize()
long	getMaxBatchSizeInBytes()
int	getMaxBufferedRequests()
int	getMaxInFlightRequests()
long	getMaxRecordSizeInBytes()
long	getMaxTimeInBufferMS()
NetworkConfig	getNetworkConfig()
String	getPassword()
Map<TableId,String>	getShardingKey()
String	getShardingSeparator()
String	getUsername()
int	getVersion()

Methods inherited from class java.lang.Object

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

Constructor Detail

ElasticsearchSinkOptions

public ElasticsearchSinkOptions(int maxBatchSize,
                                int maxInFlightRequests,
                                int maxBufferedRequests,
                                long maxBatchSizeInBytes,
                                long maxTimeInBufferMS,
                                long maxRecordSizeInBytes,
                                NetworkConfig networkConfig,
                                int version,
                                String username,
                                String password)

Constructor for ElasticsearchSinkOptions.

ElasticsearchSinkOptions

public ElasticsearchSinkOptions(int maxBatchSize,
                                int maxInFlightRequests,
                                int maxBufferedRequests,
                                long maxBatchSizeInBytes,
                                long maxTimeInBufferMS,
                                long maxRecordSizeInBytes,
                                NetworkConfig networkConfig,
                                int version,
                                String username,
                                String password,
                                Map<TableId,String> shardingKey,
                                String shardingSeparator)

Method Detail

getMaxBatchSize

public int getMaxBatchSize()

Returns:

the maximum batch size

getMaxInFlightRequests

public int getMaxInFlightRequests()

Returns:

the maximum number of in-flight requests

getMaxBufferedRequests

public int getMaxBufferedRequests()

Returns:

the maximum number of buffered requests

getMaxBatchSizeInBytes

public long getMaxBatchSizeInBytes()

Returns:

the maximum batch size in bytes

getMaxTimeInBufferMS

public long getMaxTimeInBufferMS()

Returns:

the maximum time in buffer in milliseconds

getMaxRecordSizeInBytes

public long getMaxRecordSizeInBytes()

Returns:

the maximum record size in bytes

getNetworkConfig

public NetworkConfig getNetworkConfig()

Returns:

the network configuration

getHosts

public List<org.apache.http.HttpHost> getHosts()

Returns:

the list of Elasticsearch hosts

getVersion

public int getVersion()

getUsername

public String getUsername()

getPassword

public String getPassword()

getShardingKey

public Map<TableId,String> getShardingKey()

getShardingSeparator

public String getShardingSeparator()