Class 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 Detail

      • HybridSourceSplitSerializer

        public HybridSourceSplitSerializer()
    • Method Detail

      • getVersion

        public int getVersion()
        Specified by:
        getVersion in interface org.apache.flink.core.io.SimpleVersionedSerializer<HybridSourceSplit>
        Specified by:
        getVersion in interface org.apache.flink.core.io.Versioned