Package org.apache.flink.connector.base.source.hybrid

Class HybridSourceEnumeratorStateSerializer

java.lang.Object

org.apache.flink.connector.base.source.hybrid.HybridSourceEnumeratorStateSerializer

All Implemented Interfaces:

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

public class HybridSourceEnumeratorStateSerializer
extends Object
implements org.apache.flink.core.io.SimpleVersionedSerializer<HybridSourceEnumeratorState>

The Serializer for the enumerator state.

Constructor Summary

Constructors

Constructor	Description
HybridSourceEnumeratorStateSerializer()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

HybridSourceEnumeratorStateSerializer

public HybridSourceEnumeratorStateSerializer()

Method Detail

getVersion

public int getVersion()

Specified by:

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

Specified by:

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

serialize

public byte[] serialize(HybridSourceEnumeratorState enumState)
                 throws IOException

Specified by:

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

Throws:

IOException

deserialize

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

Specified by:

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

Throws:

IOException