@InterfaceStability.Evolving public interface ContinuousInputPartitionReader<T> extends InputPartitionReader<T>
InputPartitionReader
for use with streaming in continuous processing mode.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()