Class RecordAndPosition<T>
java.lang.Object
org.apache.iceberg.flink.source.reader.RecordAndPosition<T>
A record along with the reader position to be stored in the checkpoint.
The position defines the point in the reader AFTER the record. Record processing and updating checkpointed state happens atomically. The position points to where the reader should resume after this record is processed.
This mutable object is useful in cases where only one instance of a RecordAndPosition
is needed at a time. Then the same instance of RecordAndPosition can be reused.
-
Constructor Summary
-
Method Summary
-
Constructor Details
-
RecordAndPosition
-
RecordAndPosition
public RecordAndPosition()
-
-
Method Details