Google Cloud Dataflow SDK for Java, version 1.9.1
Package com.google.cloud.dataflow.sdk
Provides a simple, powerful model for building both batch and
streaming parallel data processing
Pipeline
s.See: Description
-
Interface Summary Interface Description Pipeline.PipelineVisitor APipeline.PipelineVisitor
can be passed intoPipeline.traverseTopologically(com.google.cloud.dataflow.sdk.Pipeline.PipelineVisitor)
to be called for each of the transforms and values in thePipeline
.PipelineResult Result ofPipeline.run()
. -
Class Summary Class Description Pipeline APipeline
manages a directed acyclic graph ofPTransforms
, and thePCollections
that thePTransform
s consume and produce. -
Enum Summary Enum Description PipelineResult.State Named constants for common values for the job state. -
Exception Summary Exception Description Pipeline.PipelineExecutionException
Package com.google.cloud.dataflow.sdk Description
Provides a simple, powerful model for building both batch and
streaming parallel data processing
Pipeline
s.
To use the Google Cloud Dataflow SDK, you build a
Pipeline
, which manages a graph of
PTransform
s
and the PCollection
s that
the PTransforms consume and produce.
Each Pipeline has a
PipelineRunner
to specify
where and how it should run after pipeline construction is complete.