Remove dead code from MetricsContainer
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5fc68a5c Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/5fc68a5c Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/5fc68a5c Branch: refs/heads/master Commit: 5fc68a5c109fdbe3ed8afb370c8fcee803e9f1d8 Parents: 4852d2e Author: bchambers <bchamb...@google.com> Authored: Thu Nov 17 14:40:52 2016 -0800 Committer: bchambers <bchamb...@google.com> Committed: Fri Nov 18 09:55:29 2016 -0800 ---------------------------------------------------------------------- .../org/apache/beam/sdk/metrics/MetricsContainer.java | 13 ------------- 1 file changed, 13 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/5fc68a5c/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricsContainer.java ---------------------------------------------------------------------- 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 10032a2..ba5a343 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 @@ public class MetricsContainer { * container. */ public MetricUpdates getCumulative() { - ImmutableList.Builder<MetricUpdate<Long>> counterUpdates = ImmutableList.builder(); - for (Map.Entry<MetricName, CounterCell> counter : counters.entries()) { - counterUpdates.add(MetricUpdate.create( - MetricKey.create(stepName, counter.getKey()), counter.getValue().getCumulative())); - } - - ImmutableList.Builder<MetricUpdate<DistributionData>> distributionUpdates = - ImmutableList.builder(); - for (Map.Entry<MetricName, DistributionCell> distribution : distributions.entries()) { - distributionUpdates.add(MetricUpdate.create( - MetricKey.create(stepName, distribution.getKey()), - distribution.getValue().getCumulative())); - } return MetricUpdates.create( extractCumulatives(counters), extractCumulatives(distributions));
