com.google.cloud.dataflow.sdk.runners.inprocess (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

Warning: Dataflow SDK 1.x for Java is unsupported as of October 16, 2018. After August 12, 2020, Dataflow will not run jobs using Dataflow 1.x and below. See Migrating from Dataflow SDK 1.x for Java for migration guidance.

Note: If you are using Cloud Dataflow SDK version 2.x, see the Apache Beam API reference documentation.

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.