Package org.apache.beam.sdk
@DefaultAnnotation(org.checkerframework.checker.nullness.qual.NonNull.class)
package org.apache.beam.sdk
Provides a simple, powerful model for building both batch and streaming parallel data processing
Pipelines.
To use the Apache Beam 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.
-
ClassDescriptionA
Pipelinemanages a directed acyclic graph ofPTransforms, and thePCollectionsthat thePTransformsconsume and produce.For internal use only; no backwards-compatibility guarantees.Control enum for indicating whether or not a traversal should process the contents of a composite transform or not.Default no-opPipeline.PipelineVisitorthat enters all composite transforms.Result ofPipeline.run().Possible job states, for both completed and ongoing jobs.PipelineRunner<ResultT extends PipelineResult>APipelineRunnerruns aPipeline.