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

Class DataflowMetricUpdateExtractor

java.lang.Object

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

public final class DataflowMetricUpdateExtractor
extends Object

Methods for extracting the values of an Aggregator from a collection of MetricUpdates.

Method Summary

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.

Methods inherited from class java.lang.Object

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

Method Detail

fromMetricUpdates

public 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.