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