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

Class Elasticsearch8AsyncSinkSerializer

java.lang.Object

org.apache.flink.connector.base.sink.writer.AsyncSinkWriterStateSerializer<Operation>

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

All Implemented Interfaces:

org.apache.flink.core.io.SimpleVersionedSerializer<org.apache.flink.connector.base.sink.writer.BufferedRequestState<Operation>>, org.apache.flink.core.io.Versioned

public class Elasticsearch8AsyncSinkSerializer
extends org.apache.flink.connector.base.sink.writer.AsyncSinkWriterStateSerializer<Operation>

Elasticsearch8AsyncSinkSerializer is used to serialize and deserialize Operation objects for Elasticsearch 8 async sink.

Constructor Summary

Constructors

Constructor	Description
Elasticsearch8AsyncSinkSerializer()

Method Summary

Modifier and Type	Method	Description
protected Operation	deserializeRequestFromStream(long requestSize, DataInputStream in)	Deserializes an Operation from the provided DataInputStream.
int	getVersion()	Returns the version of this serializer.
protected void	serializeRequestToStream(Operation request, DataOutputStream out)	Serializes the given Operation to the provided DataOutputStream.

Methods inherited from class org.apache.flink.connector.base.sink.writer.AsyncSinkWriterStateSerializer

deserialize, serialize

Methods inherited from class java.lang.Object

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

Constructor Detail

Elasticsearch8AsyncSinkSerializer

public Elasticsearch8AsyncSinkSerializer()

Method Detail

serializeRequestToStream

protected void serializeRequestToStream(Operation request,
                                        DataOutputStream out)

Serializes the given Operation to the provided DataOutputStream.

Specified by:

serializeRequestToStream in class org.apache.flink.connector.base.sink.writer.AsyncSinkWriterStateSerializer<Operation>

Parameters:

request - the Operation to serialize.

out - the DataOutputStream to which the Operation will be serialized.

deserializeRequestFromStream

protected Operation deserializeRequestFromStream(long requestSize,
                                                 DataInputStream in)

Deserializes an Operation from the provided DataInputStream.

Specified by:

deserializeRequestFromStream in class org.apache.flink.connector.base.sink.writer.AsyncSinkWriterStateSerializer<Operation>

Parameters:

requestSize - the size of the request in bytes.

in - the DataInputStream from which the Operation will be deserialized.

Returns:

the deserialized Operation.

getVersion

public int getVersion()

Returns the version of this serializer.

Returns:

the version number.