IN
- type of the records converted to Elasticsearch actions@PublicEvolving public class Elasticsearch6SinkBuilder<IN> extends ElasticsearchSinkBuilderBase<IN,Elasticsearch6SinkBuilder<IN>>
ElasticsearchSink
.
The following example shows the minimal setup to create a ElasticsearchSink that submits actions on checkpoint or the default number of actions was buffered (1000).
ElasticsearchSink<String> sink = new Elasticsearch6SinkBuilder<String>()
.setHosts(new HttpHost("localhost:9200")
.setEmitter((element, context, indexer) -> {
indexer.add(
new IndexRequest("my-index","my-type")
.id(element.f0.toString())
.source(element.f1)
);
})
.build();
emitter
Constructor and Description |
---|
Elasticsearch6SinkBuilder() |
Modifier and Type | Method and Description |
---|---|
protected org.apache.flink.connector.elasticsearch.sink.BulkProcessorBuilderFactory |
getBulkProcessorBuilderFactory() |
<T extends IN> |
setEmitter(ElasticsearchEmitter<? super T> emitter)
Sets the emitter which is invoked on every record to convert it to Elasticsearch actions.
|
build, self, setBulkFlushBackoffStrategy, setBulkFlushInterval, setBulkFlushMaxActions, setBulkFlushMaxSizeMb, setConnectionPassword, setConnectionPathPrefix, setConnectionRequestTimeout, setConnectionTimeout, setConnectionUsername, setDeliveryGuarantee, setHosts, setSocketTimeout, toString
public <T extends IN> Elasticsearch6SinkBuilder<T> setEmitter(ElasticsearchEmitter<? super T> emitter)
ElasticsearchSinkBuilderBase
setEmitter
in class ElasticsearchSinkBuilderBase<IN,Elasticsearch6SinkBuilder<IN>>
emitter
- to process records into Elasticsearch actions.protected org.apache.flink.connector.elasticsearch.sink.BulkProcessorBuilderFactory getBulkProcessorBuilderFactory()
getBulkProcessorBuilderFactory
in class ElasticsearchSinkBuilderBase<IN,Elasticsearch6SinkBuilder<IN>>
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.