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, you can use unsupported SDKs temporarily while you upgrade your pipelines. For more information, see Using an unsupported SDK.

For information on migrating from the 1.x SDK, see Migrating from Dataflow SDK 1.x for Java.

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.