Interface | Description |
---|---|
ElasticsearchEmitter<T> |
Creates none or multiple
ActionRequests from the incoming elements. |
RequestIndexer |
Users add multiple delete, index or update requests to a
RequestIndexer to prepare them
for sending to an Elasticsearch cluster. |
Class | Description |
---|---|
Elasticsearch6SinkBuilder<IN> |
Builder to construct an Elasticsearch 6 compatible
ElasticsearchSink . |
Elasticsearch7SinkBuilder<IN> |
Builder to construct an Elasticsearch 7 compatible
ElasticsearchSink . |
ElasticsearchSink<IN> |
Flink Sink to insert or update data in an Elasticsearch index.
|
ElasticsearchSinkBuilderBase<IN,B extends ElasticsearchSinkBuilderBase<IN,B>> |
Base builder to construct a
ElasticsearchSink . |
MapElasticsearchEmitter |
A simple ElasticsearchEmitter which is currently used in PyFlink ES connector.
|
Enum | Description |
---|---|
FlushBackoffType |
Used to control whether the sink should retry failed requests at all or with which kind back off
strategy.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.