Closes #2223
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/59aa0dab Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/59aa0dab Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/59aa0dab Branch: refs/heads/master Commit: 59aa0dab728213cfdb049892b09ac09a1c3b3846 Parents: 1d9772a 6de412a Author: bchambers <[email protected]> Authored: Mon Mar 20 14:48:56 2017 -0700 Committer: bchambers <[email protected]> Committed: Mon Mar 20 14:48:56 2017 -0700 ---------------------------------------------------------------------- .../beam/runners/direct/DirectMetrics.java | 70 +----- .../beam/runners/direct/DirectMetricsTest.java | 86 ++----- .../beam/runners/dataflow/DataflowMetrics.java | 212 +++++++++++++++++ .../runners/dataflow/DataflowPipelineJob.java | 14 +- .../runners/dataflow/DataflowMetricsTest.java | 236 +++++++++++++++++++ .../beam/sdk/metrics/MetricFiltering.java | 99 ++++++++ .../beam/sdk/metrics/MetricFilteringTest.java | 72 ++++++ 7 files changed, 655 insertions(+), 134 deletions(-) ----------------------------------------------------------------------
