BoundedSource
BoundedSource Extensions
OffsetBasedSource is the only known BoundedSource extension.
Contract
createReader Method
BoundedReader<T> createReader(
PipelineOptions options)
Creates a BoundedReader (based on the given PipelineOptions)