org.apache.flink.streaming.connectors.elasticsearch

Interface ElasticsearchUpsertTableSinkBase.RequestFactory

All Superinterfaces:

Serializable

Enclosing class:

ElasticsearchUpsertTableSinkBase

public static interface ElasticsearchUpsertTableSinkBase.RequestFactory
extends Serializable

For version-agnostic creating of ActionRequests.

Method Summary

Modifier and Type	Method and Description
org.elasticsearch.action.delete.DeleteRequest	createDeleteRequest(String index, String docType, String key) Creates a delete request to be added to a RequestIndexer.
org.elasticsearch.action.index.IndexRequest	createIndexRequest(String index, String docType, org.elasticsearch.common.xcontent.XContentType contentType, byte[] document) Creates an index request to be added to a RequestIndexer.
org.elasticsearch.action.update.UpdateRequest	createUpdateRequest(String index, String docType, String key, org.elasticsearch.common.xcontent.XContentType contentType, byte[] document) Creates an update request to be added to a RequestIndexer.

Method Detail

createUpdateRequest

org.elasticsearch.action.update.UpdateRequest createUpdateRequest(String index,
                                                                  String docType,
                                                                  String key,
                                                                  org.elasticsearch.common.xcontent.XContentType contentType,
                                                                  byte[] document)

Creates an update request to be added to a RequestIndexer.

createIndexRequest

org.elasticsearch.action.index.IndexRequest createIndexRequest(String index,
                                                               String docType,
                                                               org.elasticsearch.common.xcontent.XContentType contentType,
                                                               byte[] document)

Creates an index request to be added to a RequestIndexer.

createDeleteRequest

org.elasticsearch.action.delete.DeleteRequest createDeleteRequest(String index,
                                                                  String docType,
                                                                  String key)

Creates a delete request to be added to a RequestIndexer.