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 Summary

Constructors

Constructor

Description

IcebergEnumeratorState(Collection<IcebergSourceSplitState> pendingSplits)

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

IcebergEnumeratorState(org.apache.iceberg.flink.source.enumerator.IcebergEnumeratorPosition lastEnumeratedPosition, Collection<IcebergSourceSplitState> pendingSplits, int[] enumerationSplitCountHistory)
Method Summary

Modifier and Type

Method

Description

int[]

enumerationSplitCountHistory()

org.apache.iceberg.flink.source.enumerator.IcebergEnumeratorPosition

lastEnumeratedPosition()

Collection<IcebergSourceSplitState>

pendingSplits()

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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()