org.apache.flink.streaming.connectors.elasticsearch7

Class Elasticsearch7UpsertTableSink

java.lang.Object

org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchUpsertTableSinkBase

org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7UpsertTableSink

All Implemented Interfaces:

StreamTableSink<Tuple2<Boolean,Row>>, TableSink<Tuple2<Boolean,Row>>, UpsertStreamTableSink<Row>

@Internal
public class Elasticsearch7UpsertTableSink
extends ElasticsearchUpsertTableSinkBase

Version-specific upsert table sink for Elasticsearch 7.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchUpsertTableSinkBase

ElasticsearchUpsertTableSinkBase.ElasticsearchUpsertSinkFunction, ElasticsearchUpsertTableSinkBase.Host, ElasticsearchUpsertTableSinkBase.RequestFactory, ElasticsearchUpsertTableSinkBase.SinkOption

Constructor Summary

Constructors

Constructor and Description
Elasticsearch7UpsertTableSink(boolean isAppendOnly, TableSchema schema, List<ElasticsearchUpsertTableSinkBase.Host> hosts, String index, String keyDelimiter, String keyNullLiteral, SerializationSchema<Row> serializationSchema, org.elasticsearch.common.xcontent.XContentType contentType, ActionRequestFailureHandler failureHandler, Map<ElasticsearchUpsertTableSinkBase.SinkOption,String> sinkOptions)

Method Summary

Modifier and Type	Method and Description
protected ElasticsearchUpsertTableSinkBase	copy(boolean isAppendOnly, TableSchema schema, List<ElasticsearchUpsertTableSinkBase.Host> hosts, String index, String docType, String keyDelimiter, String keyNullLiteral, SerializationSchema<Row> serializationSchema, org.elasticsearch.common.xcontent.XContentType contentType, ActionRequestFailureHandler failureHandler, Map<ElasticsearchUpsertTableSinkBase.SinkOption,String> sinkOptions, ElasticsearchUpsertTableSinkBase.RequestFactory requestFactory)
protected SinkFunction<Tuple2<Boolean,Row>>	createSinkFunction(List<ElasticsearchUpsertTableSinkBase.Host> hosts, ActionRequestFailureHandler failureHandler, Map<ElasticsearchUpsertTableSinkBase.SinkOption,String> sinkOptions, ElasticsearchUpsertTableSinkBase.ElasticsearchUpsertSinkFunction upsertSinkFunction)

Methods inherited from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchUpsertTableSinkBase

configure, consumeDataStream, emitDataStream, equals, getFieldNames, getFieldTypes, getOutputType, getRecordType, hashCode, setIsAppendOnly, setKeyFields

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.table.sinks.TableSink

getConsumedDataType, getTableSchema

Constructor Detail

Elasticsearch7UpsertTableSink

public Elasticsearch7UpsertTableSink(boolean isAppendOnly,
                                     TableSchema schema,
                                     List<ElasticsearchUpsertTableSinkBase.Host> hosts,
                                     String index,
                                     String keyDelimiter,
                                     String keyNullLiteral,
                                     SerializationSchema<Row> serializationSchema,
                                     org.elasticsearch.common.xcontent.XContentType contentType,
                                     ActionRequestFailureHandler failureHandler,
                                     Map<ElasticsearchUpsertTableSinkBase.SinkOption,String> sinkOptions)

Method Detail

copy

protected ElasticsearchUpsertTableSinkBase copy(boolean isAppendOnly,
                                                TableSchema schema,
                                                List<ElasticsearchUpsertTableSinkBase.Host> hosts,
                                                String index,
                                                String docType,
                                                String keyDelimiter,
                                                String keyNullLiteral,
                                                SerializationSchema<Row> serializationSchema,
                                                org.elasticsearch.common.xcontent.XContentType contentType,
                                                ActionRequestFailureHandler failureHandler,
                                                Map<ElasticsearchUpsertTableSinkBase.SinkOption,String> sinkOptions,
                                                ElasticsearchUpsertTableSinkBase.RequestFactory requestFactory)

Specified by:

copy in class ElasticsearchUpsertTableSinkBase

createSinkFunction

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

Specified by:

createSinkFunction in class ElasticsearchUpsertTableSinkBase