You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ro...@apache.org on 2016/10/27 17:28:25 UTC
[37/50] [abbrv] 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/python-sdk
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(-)
----------------------------------------------------------------------