org.apache.paimon.flink.sink

Class WrappedManifestCommittableSerializer

java.lang.Object

org.apache.paimon.flink.sink.WrappedManifestCommittableSerializer

All Implemented Interfaces:

VersionedSerializer<WrappedManifestCommittable>

public class WrappedManifestCommittableSerializer
extends Object
implements VersionedSerializer<WrappedManifestCommittable>

VersionedSerializer for ManifestCommittable.

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	CURRENT_VERSION

Constructor Summary

Constructors

Constructor and Description
WrappedManifestCommittableSerializer()

Method Summary

Modifier and Type	Method and Description
WrappedManifestCommittable	deserialize(int version, byte[] serialized) De-serializes the given data (bytes) which was serialized with the scheme of the indicated version.
int	getVersion() Gets the version with which this serializer serializes.
byte[]	serialize(WrappedManifestCommittable wrapped) Serializes the given object.

Methods inherited from class java.lang.Object

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

Field Detail

CURRENT_VERSION

protected static final int CURRENT_VERSION

See Also:

Constant Field Values

Constructor Detail

WrappedManifestCommittableSerializer

public WrappedManifestCommittableSerializer()

Method Detail

getVersion

public int getVersion()

Description copied from interface: VersionedSerializer

Gets the version with which this serializer serializes.

Specified by:

getVersion in interface VersionedSerializer<WrappedManifestCommittable>

Returns:

The version of the serialization schema.

serialize

public byte[] serialize(WrappedManifestCommittable wrapped)
                 throws IOException

Description copied from interface: VersionedSerializer

Serializes the given object. The serialization is assumed to correspond to the current serialization version (as returned by VersionedSerializer.getVersion().

Specified by:

serialize in interface VersionedSerializer<WrappedManifestCommittable>

Parameters:

wrapped - The object to serialize.

Returns:

The serialized data (bytes).

Throws:

IOException - Thrown, if the serialization fails.

deserialize

public WrappedManifestCommittable deserialize(int version,
                                              byte[] serialized)
                                       throws IOException

Description copied from interface: VersionedSerializer

De-serializes the given data (bytes) which was serialized with the scheme of the indicated version.

Specified by:

deserialize in interface VersionedSerializer<WrappedManifestCommittable>

Parameters:

version - The version in which the data was serialized

serialized - The serialized data

Returns:

The deserialized object

Throws:

IOException - Thrown, if the deserialization fails.