From c7f25639874d0127bc0c8949c43b43bc28f0af8c Mon Sep 17 00:00:00 2001 From: bchambers Date: Thu, 17 Nov 2016 14:40:52 -0800 Subject: [PATCH] Remove dead code from MetricsContainer --- .../apache/beam/sdk/metrics/MetricsContainer.java | 13 ------------- 1 file changed, 13 deletions(-) diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricsContainer.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricsContainer.java index 10032a29d1b48..ba5a343e79f1c 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricsContainer.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricsContainer.java @@ -130,19 +130,6 @@ ImmutableList> extractCumulatives( * container. */ public MetricUpdates getCumulative() { - ImmutableList.Builder> counterUpdates = ImmutableList.builder(); - for (Map.Entry counter : counters.entries()) { - counterUpdates.add(MetricUpdate.create( - MetricKey.create(stepName, counter.getKey()), counter.getValue().getCumulative())); - } - - ImmutableList.Builder> distributionUpdates = - ImmutableList.builder(); - for (Map.Entry distribution : distributions.entries()) { - distributionUpdates.add(MetricUpdate.create( - MetricKey.create(stepName, distribution.getKey()), - distribution.getValue().getCumulative())); - } return MetricUpdates.create( extractCumulatives(counters), extractCumulatives(distributions));