Class IcebergEnumeratorState

java.lang.Object
org.apache.iceberg.flink.source.enumerator.IcebergEnumeratorState
All Implemented Interfaces:
Serializable

@Internal public class IcebergEnumeratorState extends Object implements Serializable
Enumerator state for checkpointing
See Also:
  • Constructor Details

    • IcebergEnumeratorState

      public IcebergEnumeratorState(Collection<IcebergSourceSplitState> pendingSplits)
    • IcebergEnumeratorState

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

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

    • lastEnumeratedPosition

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

      public Collection<IcebergSourceSplitState> pendingSplits()
    • enumerationSplitCountHistory

      public int[] enumerationSplitCountHistory()