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.
WatermarkManager<ExecutableT,CollectionT>	Manages watermarks of PCollections and input and output watermarks of AppliedPTransforms to provide event-time and completion tracking for in-memory execution.
WatermarkManager.FiredTimers<ExecutableT>	A pair of TimerInternals.TimerData and key which can be delivered to the appropriate AppliedPTransform.
WatermarkManager.TimerUpdate	A collection of newly set, deleted, and completed timers.
WatermarkManager.TimerUpdate.TimerUpdateBuilder	A WatermarkManager.TimerUpdate builder that needs to be provided with set timers and deleted timers.

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.