BoundedSource<T> is an extension of the Source abstraction for sources that produce an finite (bounded) amount of input (of type T).

BoundedSource Extensions

OffsetBasedSource is the only known BoundedSource extension.


createReader Method

BoundedReader<T> createReader(
  PipelineOptions options)

Creates a BoundedReader (based on the given PipelineOptions)

getEstimatedSizeBytes Method

long getEstimatedSizeBytes(
  PipelineOptions options)

split Method

List<? extends BoundedSource<T>> split(
  long desiredBundleSizeBytes,
  PipelineOptions options)