Package org.apache.beam.runners.direct

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

See: Description

Interface Summary

Interface	Description
DirectOptions	Options that can be used to configure the DirectRunner.
DirectTestOptions	Internal-only options for tweaking the behavior of the DirectRunner in ways that users should never do.
TransformExecutor	A Runnable that will execute a PTransform on some bundle of input.

Class Summary

Class	Description
DirectOptions.AvailableParallelismFactory	A DefaultValueFactory that returns the result of Runtime.availableProcessors() from the DirectOptions.AvailableParallelismFactory.create(PipelineOptions) method.
DirectRegistrar	Contains the PipelineRunnerRegistrar and PipelineOptionsRegistrar for the DirectRunner.
DirectRegistrar.Options	Registers the DirectOptions.
DirectRegistrar.Runner	Registers the DirectRunner.
DirectRunner	A PipelineRunner that executes a Pipeline within the process that constructed the Pipeline.
DirectRunner.DirectPipelineResult	The result of running a Pipeline with the DirectRunner.

Package org.apache.beam.runners.direct 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.