IN- type of the records converted to Elasticsearch actions
@PublicEvolving public class ElasticsearchSink<IN> extends Object implements Sink<IN>
DeliveryGuarantee.NONEdoes 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_ONCEon 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.
|Modifier and Type||Method and Description|
public SinkWriter<IN> createWriter(Sink.InitContext context) throws IOException
context- the runtime context.
IOException- for any failure during creation.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.