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

Class Summary

Class	Description
Elasticsearch8AsyncSink<InputT>	Elasticsearch8AsyncSink is Apache Flink's Async Sink that submits Operations into an Elasticsearch cluster.
Elasticsearch8AsyncSinkBuilder<InputT>	Elasticsearch8AsyncSinkBuilder The builder to construct the Elasticsearch8Sink Elasticsearch8AsyncSink.
Elasticsearch8AsyncSinkBuilder.OperationConverter<T>	A wrapper that evolves the Operation, since a BulkOperationVariant is not Serializable.
Elasticsearch8AsyncSinkSerializer	Elasticsearch8AsyncSinkSerializer is used to serialize and deserialize Operation objects for Elasticsearch 8 async sink.
Elasticsearch8AsyncWriter<InputT>	Elasticsearch8AsyncWriter Apache Flink's Async Sink Writer that submits Operations into an Elasticsearch cluster.
NetworkConfig	A factory that creates valid ElasticsearchClient instances.
Operation	A single stream element which contains a BulkOperationVariant.
OperationSerializer	OperationSerializer is responsible for the serialization and deserialization of an Operation.