Package | Description |
---|---|
org.apache.flink.table.descriptors |
Modifier and Type | Method and Description |
---|---|
Elasticsearch |
Elasticsearch.bulkFlushBackoffConstant()
Configures how to buffer elements before sending them in bulk to the cluster for efficiency.
|
Elasticsearch |
Elasticsearch.bulkFlushBackoffDelay(long delay)
Configures how to buffer elements before sending them in bulk to the cluster for efficiency.
|
Elasticsearch |
Elasticsearch.bulkFlushBackoffExponential()
Configures how to buffer elements before sending them in bulk to the cluster for efficiency.
|
Elasticsearch |
Elasticsearch.bulkFlushBackoffMaxRetries(int maxRetries)
Configures how to buffer elements before sending them in bulk to the cluster for efficiency.
|
Elasticsearch |
Elasticsearch.bulkFlushInterval(long interval)
Configures how to buffer elements before sending them in bulk to the cluster for efficiency.
|
Elasticsearch |
Elasticsearch.bulkFlushMaxActions(int maxActions)
Configures how to buffer elements before sending them in bulk to the cluster for efficiency.
|
Elasticsearch |
Elasticsearch.bulkFlushMaxSize(String maxSize)
Configures how to buffer elements before sending them in bulk to the cluster for efficiency.
|
Elasticsearch |
Elasticsearch.connectionMaxRetryTimeout(int maxRetryTimeout)
Sets connection properties to be used during REST communication to Elasticsearch.
|
Elasticsearch |
Elasticsearch.connectionPathPrefix(String pathPrefix)
Sets connection properties to be used during REST communication to Elasticsearch.
|
Elasticsearch |
Elasticsearch.disableFlushOnCheckpoint()
Disables flushing on checkpoint.
|
Elasticsearch |
Elasticsearch.documentType(String documentType)
Declares the Elasticsearch document type for every record.
|
Elasticsearch |
Elasticsearch.failureHandlerCustom(Class<? extends ActionRequestFailureHandler> failureHandlerClass)
Configures a failure handling strategy in case a request to Elasticsearch fails.
|
Elasticsearch |
Elasticsearch.failureHandlerFail()
Configures a failure handling strategy in case a request to Elasticsearch fails.
|
Elasticsearch |
Elasticsearch.failureHandlerIgnore()
Configures a failure handling strategy in case a request to Elasticsearch fails.
|
Elasticsearch |
Elasticsearch.failureHandlerRetryRejected()
Configures a failure handling strategy in case a request to Elasticsearch fails.
|
Elasticsearch |
Elasticsearch.host(String hostname,
int port,
String protocol)
Adds an Elasticsearch host to connect to.
|
Elasticsearch |
Elasticsearch.index(String index)
Declares the Elasticsearch index for every record.
|
Elasticsearch |
Elasticsearch.keyDelimiter(String keyDelimiter)
Sets a custom key delimiter in case the Elasticsearch ID needs to be constructed from
multiple fields.
|
Elasticsearch |
Elasticsearch.keyNullLiteral(String keyNullLiteral)
Sets a custom representation for null fields in keys.
|
Elasticsearch |
Elasticsearch.version(String version)
Sets the Elasticsearch version to be used.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.