com.google.cloud.dataflow.sdk.runners.dataflow

Class DataflowAggregatorTransforms

java.lang.Object

com.google.cloud.dataflow.sdk.runners.dataflow.DataflowAggregatorTransforms

public class DataflowAggregatorTransforms
extends Object

A mapping relating Aggregators and the PTransform in which they are used.

Constructor Summary

Constructors

Constructor and Description
DataflowAggregatorTransforms(Map<Aggregator<?,?>,Collection<PTransform<?,?>>> aggregatorTransforms, Map<AppliedPTransform<?,?,?>,String> transformStepNames)

Method Summary

Modifier and Type	Method and Description
boolean	contains(Aggregator<?,?> aggregator) Returns true if the provided Aggregator is used in the constructing Pipeline.
Collection<String>	getAggregatorStepNames(Aggregator<?,?> aggregator) Gets the step names in which the Aggregator is used.
AppliedPTransform<?,?,?>	getAppliedTransformForStepName(String stepName) Gets the PTransform that was assigned the provided step name.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DataflowAggregatorTransforms

public DataflowAggregatorTransforms(Map<Aggregator<?,?>,Collection<PTransform<?,?>>> aggregatorTransforms,
                                    Map<AppliedPTransform<?,?,?>,String> transformStepNames)

Method Detail

contains

public boolean contains(Aggregator<?,?> aggregator)

Returns true if the provided Aggregator is used in the constructing Pipeline.

getAggregatorStepNames

public Collection<String> getAggregatorStepNames(Aggregator<?,?> aggregator)

Gets the step names in which the Aggregator is used.

getAppliedTransformForStepName

public AppliedPTransform<?,?,?> getAppliedTransformForStepName(String stepName)

Gets the PTransform that was assigned the provided step name.