org.apache.paimon.flink.sink

Class CommittableSerializer

java.lang.Object

org.apache.paimon.flink.sink.CommittableSerializer

All Implemented Interfaces:

org.apache.flink.core.io.SimpleVersionedSerializer<Committable>, org.apache.flink.core.io.Versioned

public class CommittableSerializer
extends Object
implements org.apache.flink.core.io.SimpleVersionedSerializer<Committable>

SimpleVersionedSerializer for Committable.

Constructor Summary

Constructors

Constructor and Description
CommittableSerializer(CommitMessageSerializer commitMessageSerializer)

Method Summary

Modifier and Type	Method and Description
Committable	deserialize(int committableVersion, byte[] bytes)
int	getVersion()
byte[]	serialize(Committable committable)

Methods inherited from class java.lang.Object

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

Constructor Detail

CommittableSerializer

public CommittableSerializer(CommitMessageSerializer commitMessageSerializer)

Method Detail

getVersion

public int getVersion()

Specified by:

getVersion in interface org.apache.flink.core.io.SimpleVersionedSerializer<Committable>

Specified by:

getVersion in interface org.apache.flink.core.io.Versioned

serialize

public byte[] serialize(Committable committable)
                 throws IOException

Specified by:

serialize in interface org.apache.flink.core.io.SimpleVersionedSerializer<Committable>

Throws:

IOException

deserialize

public Committable deserialize(int committableVersion,
                               byte[] bytes)
                        throws IOException

Specified by:

deserialize in interface org.apache.flink.core.io.SimpleVersionedSerializer<Committable>

Throws:

IOException