You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by am...@apache.org on 2016/10/26 18:34:18 UTC

[2/2] incubator-beam git commit: This closes #1185

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/master
Commit: 9f30b21a7b36f73685934746560cd3e02ab451e7
Parents: dc61a00 6db9424
Author: Sela <an...@paypal.com>
Authored: Wed Oct 26 21:17:12 2016 +0300
Committer: Sela <an...@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(-)
----------------------------------------------------------------------