BoundedSource

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.

Contract

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)