org.apache.paimon.flink.source

Class SimpleSourceSplitSerializer

java.lang.Object

org.apache.paimon.flink.source.SimpleSourceSplitSerializer

All Implemented Interfaces:

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

public class SimpleSourceSplitSerializer
extends Object
implements org.apache.flink.core.io.SimpleVersionedSerializer<SimpleSourceSplit>

SimpleVersionedSerializer for SimpleSourceSplit.

Constructor Summary

Constructors

Constructor and Description
SimpleSourceSplitSerializer()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleSourceSplitSerializer

public SimpleSourceSplitSerializer()

Method Detail

getVersion

public int getVersion()

Specified by:

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

Specified by:

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

serialize

public byte[] serialize(SimpleSourceSplit split)
                 throws IOException

Specified by:

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

Throws:

IOException

deserialize

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

Specified by:

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

Throws:

IOException