@Internal public class IcebergSourceSplitSerializer extends java.lang.Object implements org.apache.flink.core.io.SimpleVersionedSerializer<IcebergSourceSplit>
Modifier and Type | Field and Description |
---|---|
static IcebergSourceSplitSerializer |
INSTANCE |
Constructor and Description |
---|
IcebergSourceSplitSerializer() |
Modifier and Type | Method and Description |
---|---|
IcebergSourceSplit |
deserialize(int version,
byte[] serialized) |
int |
getVersion() |
byte[] |
serialize(IcebergSourceSplit split) |
public static final IcebergSourceSplitSerializer INSTANCE
public int getVersion()
getVersion
in interface org.apache.flink.core.io.SimpleVersionedSerializer<IcebergSourceSplit>
getVersion
in interface org.apache.flink.core.io.Versioned
public byte[] serialize(IcebergSourceSplit split) throws java.io.IOException
serialize
in interface org.apache.flink.core.io.SimpleVersionedSerializer<IcebergSourceSplit>
java.io.IOException
public IcebergSourceSplit deserialize(int version, byte[] serialized) throws java.io.IOException
deserialize
in interface org.apache.flink.core.io.SimpleVersionedSerializer<IcebergSourceSplit>
java.io.IOException