This closes #1417
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b41789e9 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b41789e9 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/b41789e9 Branch: refs/heads/gearpump-runner Commit: b41789e9c5ac8691243c796968b00a65cc11dd39 Parents: 6ec45f7 e6870a6 Author: Thomas Groh <[email protected]> Authored: Tue Nov 22 12:27:41 2016 -0800 Committer: Thomas Groh <[email protected]> Committed: Tue Nov 22 12:27:41 2016 -0800 ---------------------------------------------------------------------- .../beam/runners/direct/TransformExecutor.java | 5 +- .../beam/sdk/metrics/MetricsEnvironment.java | 60 +++++++++++++++----- .../sdk/metrics/MetricsEnvironmentTest.java | 8 +-- .../apache/beam/sdk/metrics/MetricsTest.java | 6 +- 4 files changed, 56 insertions(+), 23 deletions(-) ----------------------------------------------------------------------
