This closes #1185
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9f30b21a Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9f30b21a Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/9f30b21a Branch: refs/heads/python-sdk Commit: 9f30b21a7b36f73685934746560cd3e02ab451e7 Parents: dc61a00 6db9424 Author: Sela <ans...@paypal.com> Authored: Wed Oct 26 21:17:12 2016 +0300 Committer: Sela <ans...@paypal.com> Committed: Wed Oct 26 21:17:12 2016 +0300 ---------------------------------------------------------------------- .../metrics/AggregatorMetricSource.java | 9 +- .../metrics/WithNamedAggregatorsSupport.java | 7 +- .../spark/translation/SparkRuntimeContext.java | 2 +- .../runners/spark/ClearAggregatorsRule.java | 33 ------- .../runners/spark/InMemoryMetricsSinkRule.java | 32 ------- .../metrics/sink/ClearAggregatorsRule.java | 33 +++++++ .../metrics/sink/InMemoryMetrics.java | 15 +++- .../metrics/sink/InMemoryMetricsSinkRule.java | 31 +++++++ .../metrics/sink/NamedAggregatorsTest.java | 92 ++++++++++++++++++++ 9 files changed, 179 insertions(+), 75 deletions(-) ----------------------------------------------------------------------