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

Class Elasticsearch8AsyncSinkBuilder.OperationConverter<T>

java.lang.Object

org.apache.flink.cdc.connectors.elasticsearch.v2.Elasticsearch8AsyncSinkBuilder.OperationConverter<T>

All Implemented Interfaces:

Serializable, org.apache.flink.connector.base.sink.writer.ElementConverter<T,Operation>

Enclosing class:

Elasticsearch8AsyncSinkBuilder<InputT>

public static class Elasticsearch8AsyncSinkBuilder.OperationConverter<T>
extends Object
implements org.apache.flink.connector.base.sink.writer.ElementConverter<T,Operation>

A wrapper that evolves the Operation, since a BulkOperationVariant is not Serializable.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
OperationConverter(org.apache.flink.connector.base.sink.writer.ElementConverter<T,co.elastic.clients.elasticsearch.core.bulk.BulkOperationVariant> converter)

Method Summary

Modifier and Type	Method	Description
Operation	apply(T element, org.apache.flink.api.connector.sink2.SinkWriter.Context context)

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.connector.base.sink.writer.ElementConverter

open

Constructor Detail

OperationConverter

public OperationConverter(org.apache.flink.connector.base.sink.writer.ElementConverter<T,co.elastic.clients.elasticsearch.core.bulk.BulkOperationVariant> converter)

Method Detail

apply

public Operation apply(T element,
                       org.apache.flink.api.connector.sink2.SinkWriter.Context context)

Specified by:

apply in interface org.apache.flink.connector.base.sink.writer.ElementConverter<T,Operation>