Class IcebergSourceSplitSerializer

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

    @Internal
    public class IcebergSourceSplitSerializer
    extends java.lang.Object
    implements org.apache.flink.core.io.SimpleVersionedSerializer<IcebergSourceSplit>
    TODO: use Java serialization for now. Will switch to more stable serializer from issue-1698.
    • Constructor Detail

      • IcebergSourceSplitSerializer

        public IcebergSourceSplitSerializer()
    • Method Detail

      • getVersion

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

        public byte[] serialize​(IcebergSourceSplit split)
                         throws java.io.IOException
        Specified by:
        serialize in interface org.apache.flink.core.io.SimpleVersionedSerializer<IcebergSourceSplit>
        Throws:
        java.io.IOException
      • deserialize

        public IcebergSourceSplit deserialize​(int version,
                                              byte[] serialized)
                                       throws java.io.IOException
        Specified by:
        deserialize in interface org.apache.flink.core.io.SimpleVersionedSerializer<IcebergSourceSplit>
        Throws:
        java.io.IOException