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 2016/12/07 01:15:46 UTC
[4/4] incubator-beam git commit: Closes #1434
Closes #1434
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b2b570f2
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b2b570f2
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/b2b570f2
Branch: refs/heads/master
Commit: b2b570f27808b1671bf6cd0fc60f874da671d4ca
Parents: afedd68 ce03f30
Author: bchambers <bc...@google.com>
Authored: Tue Dec 6 17:08:13 2016 -0800
Committer: bchambers <bc...@google.com>
Committed: Tue Dec 6 17:08:13 2016 -0800
----------------------------------------------------------------------
.../beam/runners/dataflow/DataflowClient.java | 140 +++++++++++++++++++
.../runners/dataflow/DataflowPipelineJob.java | 31 ++--
.../beam/runners/dataflow/DataflowRunner.java | 20 +--
.../dataflow/testing/TestDataflowRunner.java | 6 +-
.../dataflow/util/DataflowTemplateJob.java | 2 +-
.../runners/dataflow/util/MonitoringUtil.java | 22 +--
.../dataflow/DataflowPipelineJobTest.java | 49 ++++---
.../testing/TestDataflowRunnerTest.java | 36 ++---
.../transforms/DataflowGroupByKeyTest.java | 14 +-
.../dataflow/transforms/DataflowViewTest.java | 16 ++-
.../dataflow/util/MonitoringUtilTest.java | 21 +--
11 files changed, 235 insertions(+), 122 deletions(-)
----------------------------------------------------------------------