Class IcebergEnumeratorStateSerializer

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

    @Internal
    public class IcebergEnumeratorStateSerializer
    extends java.lang.Object
    implements org.apache.flink.core.io.SimpleVersionedSerializer<IcebergEnumeratorState>
    • Constructor Detail

      • IcebergEnumeratorStateSerializer

        public IcebergEnumeratorStateSerializer​(boolean caseSensitive)
    • Method Detail

      • getVersion

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

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

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