Uses of Class
org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchUpsertTableSinkBase.ElasticsearchUpsertSinkFunction

Packages that use ElasticsearchUpsertTableSinkBase.ElasticsearchUpsertSinkFunction

Package	Description
org.apache.flink.streaming.connectors.elasticsearch
org.apache.flink.streaming.connectors.elasticsearch6
org.apache.flink.streaming.connectors.elasticsearch7

Uses of ElasticsearchUpsertTableSinkBase.ElasticsearchUpsertSinkFunction in org.apache.flink.streaming.connectors.elasticsearch

Methods in org.apache.flink.streaming.connectors.elasticsearch with parameters of type ElasticsearchUpsertTableSinkBase.ElasticsearchUpsertSinkFunction

Modifier and Type	Method and Description
protected abstract SinkFunction<Tuple2<Boolean,Row>>	ElasticsearchUpsertTableSinkBase.createSinkFunction(List<ElasticsearchUpsertTableSinkBase.Host> hosts, ActionRequestFailureHandler failureHandler, Map<ElasticsearchUpsertTableSinkBase.SinkOption,String> sinkOptions, ElasticsearchUpsertTableSinkBase.ElasticsearchUpsertSinkFunction upsertFunction)

Uses of ElasticsearchUpsertTableSinkBase.ElasticsearchUpsertSinkFunction in org.apache.flink.streaming.connectors.elasticsearch6

Methods in org.apache.flink.streaming.connectors.elasticsearch6 with parameters of type ElasticsearchUpsertTableSinkBase.ElasticsearchUpsertSinkFunction

Modifier and Type	Method and Description
protected SinkFunction<Tuple2<Boolean,Row>>	Elasticsearch6UpsertTableSink.createSinkFunction(List<ElasticsearchUpsertTableSinkBase.Host> hosts, ActionRequestFailureHandler failureHandler, Map<ElasticsearchUpsertTableSinkBase.SinkOption,String> sinkOptions, ElasticsearchUpsertTableSinkBase.ElasticsearchUpsertSinkFunction upsertSinkFunction)

Uses of ElasticsearchUpsertTableSinkBase.ElasticsearchUpsertSinkFunction in org.apache.flink.streaming.connectors.elasticsearch7

Methods in org.apache.flink.streaming.connectors.elasticsearch7 with parameters of type ElasticsearchUpsertTableSinkBase.ElasticsearchUpsertSinkFunction

Modifier and Type	Method and Description
protected SinkFunction<Tuple2<Boolean,Row>>	Elasticsearch7UpsertTableSink.createSinkFunction(List<ElasticsearchUpsertTableSinkBase.Host> hosts, ActionRequestFailureHandler failureHandler, Map<ElasticsearchUpsertTableSinkBase.SinkOption,String> sinkOptions, ElasticsearchUpsertTableSinkBase.ElasticsearchUpsertSinkFunction upsertSinkFunction)