@DefaultAnnotation(value=edu.umd.cs.findbugs.annotations.NonNull.class)
Pipeline
s.See: Description
Interface | Description |
---|---|
Pipeline.PipelineVisitor |
For internal use only; no backwards-compatibility guarantees.
|
PipelineResult |
Result of
Pipeline.run() . |
Class | Description |
---|---|
Pipeline |
A
Pipeline manages a directed acyclic graph of PTransforms , and the
PCollections that the PTransforms consume and produce. |
Pipeline.PipelineVisitor.Defaults |
Default no-op
Pipeline.PipelineVisitor that enters all composite transforms. |
PipelineRunner<ResultT extends PipelineResult> |
A
PipelineRunner runs a Pipeline . |
Enum | Description |
---|---|
Pipeline.PipelineVisitor.CompositeBehavior |
Control enum for indicating whether or not a traversal should process the contents of
a composite transform or not.
|
PipelineResult.State |
Possible job states, for both completed and ongoing jobs.
|
Exception | Description |
---|---|
Pipeline.PipelineExecutionException |
Pipeline
s.
To use the Apache Beam 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.