Class HybridSourceSplitSerializer
- java.lang.Object
-
- org.apache.flink.connector.base.source.hybrid.HybridSourceSplitSerializer
-
- All Implemented Interfaces:
org.apache.flink.core.io.SimpleVersionedSerializer<HybridSourceSplit>,org.apache.flink.core.io.Versioned
public class HybridSourceSplitSerializer extends Object implements org.apache.flink.core.io.SimpleVersionedSerializer<HybridSourceSplit>
Serializes splits by delegating to the source-indexed underlying split serializer.
-
-
Constructor Summary
Constructors Constructor Description HybridSourceSplitSerializer()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description HybridSourceSplitdeserialize(int version, byte[] serialized)intgetVersion()byte[]serialize(HybridSourceSplit split)
-
-
-
Method Detail
-
getVersion
public int getVersion()
- Specified by:
getVersionin interfaceorg.apache.flink.core.io.SimpleVersionedSerializer<HybridSourceSplit>- Specified by:
getVersionin interfaceorg.apache.flink.core.io.Versioned
-
serialize
public byte[] serialize(HybridSourceSplit split) throws IOException
- Specified by:
serializein interfaceorg.apache.flink.core.io.SimpleVersionedSerializer<HybridSourceSplit>- Throws:
IOException
-
deserialize
public HybridSourceSplit deserialize(int version, byte[] serialized) throws IOException
- Specified by:
deserializein interfaceorg.apache.flink.core.io.SimpleVersionedSerializer<HybridSourceSplit>- Throws:
IOException
-
-