Class IcebergEnumeratorState
java.lang.Object
org.apache.iceberg.flink.source.enumerator.IcebergEnumeratorState
- All Implemented Interfaces:
Serializable
Enumerator state for checkpointing
- See Also:
-
Constructor Summary
ConstructorDescriptionIcebergEnumeratorState
(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 TypeMethodDescriptionint[]
org.apache.iceberg.flink.source.enumerator.IcebergEnumeratorPosition
-
Constructor Details
-
IcebergEnumeratorState
-
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
-
enumerationSplitCountHistory
public int[] enumerationSplitCountHistory()
-