com.google.cloud.dataflow.sdk (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

Provides a simple, powerful model for building both batch and streaming parallel data processing Pipelines.

See: Description

• Interface Summary 

  Interface	Description
  Pipeline.PipelineVisitor	A Pipeline.PipelineVisitor can be passed into Pipeline.traverseTopologically(com.google.cloud.dataflow.sdk.Pipeline.PipelineVisitor) to be called for each of the transforms and values in the Pipeline.
  PipelineResult	Result of Pipeline.run().

• Class Summary 

  Class	Description
  Pipeline	A Pipeline manages a directed acyclic graph of PTransforms, and the PCollections that the PTransforms consume and produce.

• Enum Summary 

  Enum	Description
  PipelineResult.State	Named constants for common values for the job state.

• Exception Summary 

  Exception	Description
  Pipeline.PipelineExecutionException	Thrown during execution of a Pipeline, whenever user code within that Pipeline throws an exception.

Package com.google.cloud.dataflow.sdk Description

Provides a simple, powerful model for building both batch and streaming parallel data processing Pipelines.

To use the Google Cloud Dataflow SDK, you build a Pipeline, which manages a graph of PTransforms and the PCollections that the PTransforms consume and produce.

Each Pipeline has a PipelineRunner to specify where and how it should run after pipeline construction is complete.