@Internal public class Elasticsearch6UpsertTableSinkFactory extends ElasticsearchUpsertTableSinkFactoryBase
UpsertStreamTableSink
for Elasticsearch 6.Constructor and Description |
---|
Elasticsearch6UpsertTableSinkFactory() |
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() |
createStreamTableSink, requiredContext, supportedProperties
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createTableSink
createTableSink
public Elasticsearch6UpsertTableSinkFactory()
protected String elasticsearchVersion()
elasticsearchVersion
in class ElasticsearchUpsertTableSinkFactoryBase
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)
createElasticsearchUpsertTableSink
in class ElasticsearchUpsertTableSinkFactoryBase
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.