Package org.apache.flink.cdc.connectors.paimon.sink.v2

Class PaimonWriterStateSerializer

java.lang.Object

org.apache.flink.cdc.connectors.paimon.sink.v2.PaimonWriterStateSerializer

All Implemented Interfaces:

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

public class PaimonWriterStateSerializer
extends Object
implements org.apache.flink.core.io.SimpleVersionedSerializer<PaimonWriterState>

A SimpleVersionedSerializer for PaimonWriterState.

Field Summary

Fields

Modifier and Type	Field	Description
static PaimonWriterStateSerializer	INSTANCE

Constructor Summary

Constructors

Constructor	Description
PaimonWriterStateSerializer()

Method Summary

Modifier and Type	Method	Description
PaimonWriterState	deserialize(int version, byte[] serialized)
int	getVersion()
byte[]	serialize(PaimonWriterState paimonWriterState)

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE

public static final PaimonWriterStateSerializer INSTANCE

Constructor Detail

PaimonWriterStateSerializer

public PaimonWriterStateSerializer()

Method Detail

getVersion

public int getVersion()

Specified by:

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

Specified by:

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

serialize

public byte[] serialize(PaimonWriterState paimonWriterState)
                 throws IOException

Specified by:

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

Throws:

IOException

deserialize

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

Specified by:

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

Throws:

IOException