Class IcebergSourceSplit

  • All Implemented Interfaces:
    java.io.Serializable, org.apache.flink.api.connector.source.SourceSplit

    @Internal
    public class IcebergSourceSplit
    extends java.lang.Object
    implements org.apache.flink.api.connector.source.SourceSplit, java.io.Serializable
    See Also:
    Serialized Form
    • Method Detail

      • fileOffset

        public int fileOffset()
      • recordOffset

        public long recordOffset()
      • splitId

        public java.lang.String splitId()
        Specified by:
        splitId in interface org.apache.flink.api.connector.source.SourceSplit
      • updatePosition

        public void updatePosition​(int newFileOffset,
                                   long newRecordOffset)
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object