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