This closes #2083
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3082178b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3082178b Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/3082178b Branch: refs/heads/master Commit: 3082178b3a35143573caa2b3d9afbf2babb5b2b5 Parents: 4bba380 b74f8fa Author: Stas Levin <stasle...@apache.org> Authored: Mon Feb 27 14:16:55 2017 +0200 Committer: Stas Levin <stasle...@apache.org> Committed: Mon Feb 27 14:16:55 2017 +0200 ---------------------------------------------------------------------- .../runners/spark/metrics/SparkBeamMetric.java | 13 ++++- .../spark/metrics/SparkBeamMetricTest.java | 60 ++++++++++++++++++++ 2 files changed, 70 insertions(+), 3 deletions(-) ----------------------------------------------------------------------
