@Evolving public interface ContinuousPartitionReader<T> extends PartitionReader<T>
PartitionReaderfor use with continuous streaming processing.
|Modifier and Type||Method and Description|
Get the offset of the current record, or the start offset if no records have been read.
currentMetricsValues, get, next
The execution engine will call this method along with get() to keep track of the current offset. When an epoch ends, the offset of the previous record in each partition will be saved as a restart checkpoint.