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 Link icon

    • IcebergEnumeratorState Link icon

      public IcebergEnumeratorState(Collection<IcebergSourceSplitState> pendingSplits)
    • IcebergEnumeratorState Link icon

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

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

    • lastEnumeratedPosition Link icon

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

      public Collection<IcebergSourceSplitState> pendingSplits()
    • enumerationSplitCountHistory Link icon

      public int[] enumerationSplitCountHistory()