Class FromElementsSplitSerializer

  • All Implemented Interfaces:
    org.apache.flink.core.io.SimpleVersionedSerializer<FromElementsSplit>, org.apache.flink.core.io.Versioned

    public class FromElementsSplitSerializer
    extends Object
    implements org.apache.flink.core.io.SimpleVersionedSerializer<FromElementsSplit>
    The split serializer for the FromElementsSource.
    • Constructor Detail

      • FromElementsSplitSerializer

        public FromElementsSplitSerializer()
    • Method Detail

      • getVersion

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