You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by bc...@apache.org on 2017/07/18 17:26:39 UTC
[2/2] beam git commit: This closes #2896
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 <bc...@bchambers-macbookpro2.roam.corp.google.com>
Authored: Tue Jul 18 09:58:57 2017 -0700
Committer: Ben Chambers <bc...@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(-)
----------------------------------------------------------------------