Package org.apache.beam.runners.direct

package org.apache.beam.runners.direct

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

See

invalid reference

org.apache.beam.sdk.runners

for more information about Pipeline Runners.

Class	Description
Clock	Access to the current time.
DirectOptions	Options that can be used to configure the DirectRunner.
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.
DirectTestOptions	Internal-only options for tweaking the behavior of the PipelineOptions.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.
ParDoMultiOverrideFactory<InputT,OutputT>	A PTransformOverrideFactory that provides overrides for applications of a ParDo in the direct runner.
TransformExecutor	A Runnable that will execute a PTransform on some bundle of input.