Package org.apache.flink.cdc.connectors.elasticsearch.serializer

Class Elasticsearch6RequestCreator

java.lang.Object

org.apache.flink.cdc.connectors.elasticsearch.serializer.Elasticsearch6RequestCreator

public class Elasticsearch6RequestCreator
extends Object

A utility class that creates Elasticsearch 6.x specific requests.

This class provides methods to create IndexRequest and DeleteRequest objects that are compatible with Elasticsearch 6.x based on the operations provided.

Constructor Summary

Constructors

Constructor	Description
Elasticsearch6RequestCreator()

Method Summary

Modifier and Type	Method	Description
static org.apache.flink.elasticsearch6.shaded.org.elasticsearch.action.delete.DeleteRequest	createDeleteRequest(co.elastic.clients.elasticsearch.core.bulk.DeleteOperation operation)	Creates an Elasticsearch 6 DeleteRequest.
static org.apache.flink.elasticsearch6.shaded.org.elasticsearch.action.index.IndexRequest	createIndexRequest(co.elastic.clients.elasticsearch.core.bulk.IndexOperation<?> operation)	Creates an Elasticsearch 6 IndexRequest.

Methods inherited from class java.lang.Object

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

Constructor Detail

Elasticsearch6RequestCreator

public Elasticsearch6RequestCreator()

Method Detail

createIndexRequest

public static org.apache.flink.elasticsearch6.shaded.org.elasticsearch.action.index.IndexRequest createIndexRequest(co.elastic.clients.elasticsearch.core.bulk.IndexOperation<?> operation)

Creates an Elasticsearch 6 IndexRequest.

Parameters:

operation - IndexOperation object.

Returns:

IndexRequest object.

createDeleteRequest

public static org.apache.flink.elasticsearch6.shaded.org.elasticsearch.action.delete.DeleteRequest createDeleteRequest(co.elastic.clients.elasticsearch.core.bulk.DeleteOperation operation)

Creates an Elasticsearch 6 DeleteRequest.

Parameters:

operation - DeleteOperation object.

Returns:

DeleteRequest object.