pyflink.datastream.connectors.elasticsearch.ElasticsearchSink

class ElasticsearchSink(j_elasticsearch_sink)

Flink Sink to insert or update data in an Elasticsearch index. The sink supports the following delivery guarantees.

DeliveryGuarantee.NONE does not provide any guarantees: actions are flushed to Elasticsearch only depending on the configurations of the bulk processor. In case of a failure, it might happen that actions are lost if the bulk processor still has buffered actions.

DeliveryGuarantee.AT_LEAST_ONCE on a checkpoint the sink will wait until all buffered actions are flushed to and acknowledged by Elasticsearch. No actions will be lost but actions might be sent to Elasticsearch multiple times when Flink restarts. These additional requests may cause inconsistent data in ElasticSearch right after the restart, but eventually everything will be consistent again.

Methods

get_java_function()