public final class DataflowMetricUpdateExtractor extends Object
Aggregator from a collection of MetricUpdates.| Modifier and Type | Method and Description |
|---|---|
static <OutputT> Map<String,OutputT> |
fromMetricUpdates(Aggregator<?,OutputT> aggregator,
DataflowAggregatorTransforms aggregatorTransforms,
List<com.google.api.services.dataflow.model.MetricUpdate> metricUpdates)
Extract the values of the provided
Aggregator at each PTransform it was used in
according to the provided DataflowAggregatorTransforms from the given list of MetricUpdates. |
public static <OutputT> Map<String,OutputT> fromMetricUpdates(Aggregator<?,OutputT> aggregator, DataflowAggregatorTransforms aggregatorTransforms, List<com.google.api.services.dataflow.model.MetricUpdate> metricUpdates)
Aggregator at each PTransform it was used in
according to the provided DataflowAggregatorTransforms from the given list of MetricUpdates.