Package com.google.cloud.dataflow.sdk.runners.inprocess

Defines the InProcessPipelineRunner, which executes both Bounded and Unbounded Pipelines on the local machine.

See: Description

Interface Summary

Interface	Description
Clock	Access to the current time.
ExecutorServiceFactory	A factory that creates ExecutorServices.
InProcessPipelineOptions	Options that can be used to configure the InProcessPipelineRunner.
InProcessPipelineRunner.CommittedBundle<T>	Part of a PCollection.
InProcessPipelineRunner.PCollectionViewWriter<ElemT,ViewT>	A InProcessPipelineRunner.PCollectionViewWriter is responsible for writing contents of a PCollection to a storage mechanism that can be read from while constructing a PCollectionView.
InProcessPipelineRunner.UncommittedBundle<T>	Part of a PCollection.
ModelEnforcement<T>	Enforcement tools that verify that executing code conforms to the model.
ModelEnforcementFactory	Creates ModelEnforcement instances for an AppliedPTransform on an input bundle.

Class Summary

Class	Description
ForwardingPTransform<InputT extends PInput,OutputT extends POutput>	A base class for implementing PTransform overrides, which behave identically to the delegate transform but with overridden methods.
InProcessPipelineRunner	An In-Memory implementation of the Dataflow Programming Model.
InProcessPipelineRunner.InProcessPipelineResult	The result of running a Pipeline with the InProcessPipelineRunner.
InProcessRegistrar	Contains the PipelineRunnerRegistrar and PipelineOptionsRegistrar for the InProcessPipelineRunner.
InProcessRegistrar.InProcessOptions	Registers the InProcessPipelineOptions.
InProcessRegistrar.InProcessRunner	Registers the InProcessPipelineRunner.
NanosOffsetClock	A Clock that uses System.nanoTime() to track the progress of time.
StepTransformResult	An immutable InProcessTransformResult.
StepTransformResult.Builder	A builder for creating instances of StepTransformResult.

Package com.google.cloud.dataflow.sdk.runners.inprocess Description

Defines the InProcessPipelineRunner, which executes both Bounded and Unbounded Pipelines on the local machine.

See com.google.cloud.dataflow.sdk.runners for more information about Pipeline Runners.