Google Cloud Dataflow SDK for Java, version 1.9.1
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 createsExecutorServices
.InProcessPipelineOptions Options that can be used to configure theInProcessPipelineRunner
.InProcessPipelineRunner.CommittedBundle<T> Part of aPCollection
.InProcessPipelineRunner.PCollectionViewWriter<ElemT,ViewT> AInProcessPipelineRunner.PCollectionViewWriter
is responsible for writing contents of aPCollection
to a storage mechanism that can be read from while constructing aPCollectionView
.InProcessPipelineRunner.UncommittedBundle<T> Part of aPCollection
.ModelEnforcement<T> Enforcement tools that verify that executing code conforms to the model.ModelEnforcementFactory -
Class Summary Class Description ForwardingPTransform<InputT extends PInput,OutputT extends POutput> A base class for implementingPTransform
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 aPipeline
with theInProcessPipelineRunner
.InProcessRegistrar InProcessRegistrar.InProcessOptions Registers theInProcessPipelineOptions
.InProcessRegistrar.InProcessRunner Registers theInProcessPipelineRunner
.NanosOffsetClock AClock
that usesSystem.nanoTime()
to track the progress of time.StepTransformResult An immutableInProcessTransformResult
.StepTransformResult.Builder A builder for creating instances ofStepTransformResult
.
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.