@Evolving public interface ContinuousPartitionReader<T> extends PartitionReader<T>
PartitionReader
for use with continuous streaming processing.Modifier and Type | Method and Description |
---|---|
PartitionOffset |
getOffset()
Get the offset of the current record, or the start offset if no records have been read.
|
get, next
PartitionOffset getOffset()