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
Clock	Access to the current time.
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.
ExecutableGraph<ExecutableT,CollectionT>	The interface that enables querying of a graph of independently executable stages and the inputs and outputs of those stages.
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.
ParDoMultiOverrideFactory<InputT,OutputT>	A PTransformOverrideFactory that provides overrides for applications of a ParDo in the direct runner.

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.