Google Cloud Dataflow SDK for Java, version 1.9.1
com.google.cloud.dataflow.sdk.runners
Class AggregatorPipelineExtractor
- java.lang.Object
-
- com.google.cloud.dataflow.sdk.runners.AggregatorPipelineExtractor
-
public class AggregatorPipelineExtractor extends Object
RetrievesAggregators
at eachParDo
and returns aMap
ofAggregator
to thePTransforms
in which it is present.
-
-
Constructor Summary
Constructors Constructor and Description AggregatorPipelineExtractor(Pipeline pipeline)
Creates anAggregatorPipelineExtractor
for the givenPipeline
.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method and Description Map<Aggregator<?,?>,Collection<PTransform<?,?>>>
getAggregatorSteps()
-
-
-
Method Detail
-
getAggregatorSteps
public Map<Aggregator<?,?>,Collection<PTransform<?,?>>> getAggregatorSteps()
-
-