org.apache.paimon.flink.sink

Class MultiTableCommittableSerializer

java.lang.Object

org.apache.paimon.flink.sink.MultiTableCommittableSerializer

All Implemented Interfaces:

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

public class MultiTableCommittableSerializer
extends Object
implements org.apache.flink.core.io.SimpleVersionedSerializer<MultiTableCommittable>

SimpleVersionedSerializer for MultiTableCommittable. If a type info class is using this this serde of MultiTableCommittable. It should make sure that the operator that produces it will include the database, table, and commit user information. This can be done by calling MultiTableCommittable::fromCommittable.

Constructor Summary

Constructors

Constructor and Description
MultiTableCommittableSerializer(CommitMessageSerializer commitMessageSerializer)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

MultiTableCommittableSerializer

public MultiTableCommittableSerializer(CommitMessageSerializer commitMessageSerializer)

Method Detail

getVersion

public int getVersion()

Specified by:

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

Specified by:

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

serialize

public byte[] serialize(MultiTableCommittable committable)
                 throws IOException

Specified by:

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

Throws:

IOException

deserialize

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

Specified by:

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

Throws:

IOException

serializeCommittable

public byte[] serializeCommittable(MultiTableCommittable committable)
                            throws IOException

Throws:

IOException

deserializeCommittable

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

Throws:

IOException