Class IcebergEnumeratorState

  • All Implemented Interfaces:
    java.io.Serializable

    @Internal
    public class IcebergEnumeratorState
    extends java.lang.Object
    implements java.io.Serializable
    Enumerator state for checkpointing
    See Also:
    Serialized Form
    • Constructor Detail

      • IcebergEnumeratorState

        public IcebergEnumeratorState​(java.util.Collection<IcebergSourceSplitState> pendingSplits)
      • IcebergEnumeratorState

        public IcebergEnumeratorState​(@Nullable
                                      org.apache.iceberg.flink.source.enumerator.IcebergEnumeratorPosition lastEnumeratedPosition,
                                      java.util.Collection<IcebergSourceSplitState> pendingSplits)
      • IcebergEnumeratorState

        public IcebergEnumeratorState​(@Nullable
                                      org.apache.iceberg.flink.source.enumerator.IcebergEnumeratorPosition lastEnumeratedPosition,
                                      java.util.Collection<IcebergSourceSplitState> pendingSplits,
                                      int[] enumerationSplitCountHistory)
    • Method Detail

      • lastEnumeratedPosition

        @Nullable
        public org.apache.iceberg.flink.source.enumerator.IcebergEnumeratorPosition lastEnumeratedPosition()
      • enumerationSplitCountHistory

        public int[] enumerationSplitCountHistory()