Package | Description |
---|---|
org.apache.flink.connector.elasticsearch.sink |
Modifier and Type | Class and Description |
---|---|
class |
ElasticsearchSinkBuilderBase<IN,B extends ElasticsearchSinkBuilderBase<IN,B>>
Base builder to construct a
ElasticsearchSink . |
Modifier and Type | Class and Description |
---|---|
class |
Elasticsearch6SinkBuilder<IN>
Builder to construct an Elasticsearch 6 compatible
ElasticsearchSink . |
class |
Elasticsearch7SinkBuilder<IN>
Builder to construct an Elasticsearch 7 compatible
ElasticsearchSink . |
Modifier and Type | Method and Description |
---|---|
protected <S extends ElasticsearchSinkBuilderBase<?,?>> |
ElasticsearchSinkBuilderBase.self() |
Modifier and Type | Method and Description |
---|---|
<T extends IN> |
ElasticsearchSinkBuilderBase.setEmitter(ElasticsearchEmitter<? super T> emitter)
Sets the emitter which is invoked on every record to convert it to Elasticsearch actions.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.