This closes #2896
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d2201f9c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d2201f9c Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d2201f9c Branch: refs/heads/master Commit: d2201f9cf4a45e5470bc5e1032eb497937946bbb Parents: 7c36318 a48eefa Author: Ben Chambers <bchamb...@bchambers-macbookpro2.roam.corp.google.com> Authored: Tue Jul 18 09:58:57 2017 -0700 Committer: Ben Chambers <bchamb...@bchambers-macbookpro2.roam.corp.google.com> Committed: Tue Jul 18 09:58:57 2017 -0700 ---------------------------------------------------------------------- .../org/apache/beam/examples/WordCount.java | 4 + pom.xml | 2 +- .../beam/runners/dataflow/DataflowMetrics.java | 310 +++++++++++++------ .../runners/dataflow/DataflowPipelineJob.java | 4 + .../runners/dataflow/DataflowMetricsTest.java | 174 ++++++++++- .../beam/sdk/metrics/MetricResultsMatchers.java | 2 +- 6 files changed, 388 insertions(+), 108 deletions(-) ----------------------------------------------------------------------