Package org.apache.beam.runners.direct.portable

Defines the PipelineOptions.DirectRunner which executes both Bounded and Unbounded Pipelines on the local machine.

See: Description

Interface Summary

Interface	Description
TransformExecutor	A Runnable that will execute a PTransform on some bundle of input.

Class Summary

Class	Description
ReferenceRunner	The "ReferenceRunner" engine implementation.

Package org.apache.beam.runners.direct.portable Description

Defines the PipelineOptions.DirectRunner which executes both Bounded and Unbounded Pipelines on the local machine.

See org.apache.beam.sdk.runners for more information about Pipeline Runners.