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

Class OperationSerializer

java.lang.Object

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

public class OperationSerializer
extends Object

OperationSerializer is responsible for the serialization and deserialization of an Operation.

Constructor Summary

Constructors

Constructor	Description
OperationSerializer()

Method Summary

Modifier and Type	Method	Description
Operation	deserialize(long requestSize, DataInputStream in)	Deserializes an Operation from the provided DataInputStream.
void	serialize(Operation request, DataOutputStream out)	Serializes the given Operation to the provided DataOutputStream.
int	size(Operation operation)	Calculates the serialized size of the given Operation.

Methods inherited from class java.lang.Object

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

Constructor Detail

OperationSerializer

public OperationSerializer()

Method Detail

serialize

public void serialize(Operation request,
                      DataOutputStream out)

Serializes the given Operation to the provided DataOutputStream.

Parameters:

request - the Operation to serialize

out - the DataOutputStream to which the Operation will be serialized

deserialize

public Operation deserialize(long requestSize,
                             DataInputStream in)

Deserializes an Operation from the provided DataInputStream.

Parameters:

requestSize - the size of the request in bytes

in - the DataInputStream from which the Operation will be deserialized

Returns:

the deserialized Operation, or null if deserialization fails

size

public int size(Operation operation)

Calculates the serialized size of the given Operation.

Parameters:

operation - the Operation whose size is to be calculated

Returns:

the size of the serialized Operation in bytes