@InterfaceStability.Evolving public interface ContinuousDataReader<T> extends DataReader<T>
DataReader
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()