org.apache.flink.streaming.connectors.elasticsearch6

Class Elasticsearch6UpsertTableSinkFactory

java.lang.Object

org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchUpsertTableSinkFactoryBase

org.apache.flink.streaming.connectors.elasticsearch6.Elasticsearch6UpsertTableSinkFactory

All Implemented Interfaces:

StreamTableSinkFactory<Tuple2<Boolean,Row>>, TableFactory, TableSinkFactory<Tuple2<Boolean,Row>>

@Internal
public class Elasticsearch6UpsertTableSinkFactory
extends ElasticsearchUpsertTableSinkFactoryBase

Table factory for creating an UpsertStreamTableSink for Elasticsearch 6.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.table.factories.TableSinkFactory

TableSinkFactory.Context

Constructor Summary

Constructors

Constructor and Description
Elasticsearch6UpsertTableSinkFactory()

Method Summary

Modifier and Type	Method and Description
protected ElasticsearchUpsertTableSinkBase	createElasticsearchUpsertTableSink(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)
protected String	elasticsearchVersion()

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

createStreamTableSink, requiredContext, supportedProperties

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.table.factories.StreamTableSinkFactory

createTableSink

Methods inherited from interface org.apache.flink.table.factories.TableSinkFactory

createTableSink, createTableSink

Constructor Detail

Elasticsearch6UpsertTableSinkFactory

public Elasticsearch6UpsertTableSinkFactory()

Method Detail

elasticsearchVersion

protected String elasticsearchVersion()

Specified by:

elasticsearchVersion in class ElasticsearchUpsertTableSinkFactoryBase

createElasticsearchUpsertTableSink

protected ElasticsearchUpsertTableSinkBase createElasticsearchUpsertTableSink(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)

Specified by:

createElasticsearchUpsertTableSink in class ElasticsearchUpsertTableSinkFactoryBase