You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by da...@apache.org on 2016/11/01 19:52:59 UTC

[2/2] incubator-beam git commit: This closes #762

This closes #762


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1283308e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/1283308e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/1283308e

Branch: refs/heads/master
Commit: 1283308e2c99d1b0c2cf4640ad089f8a638d8163
Parents: 8390a22 4c0fab0
Author: Davor Bonaci <da...@google.com>
Authored: Tue Nov 1 12:52:36 2016 -0700
Committer: Davor Bonaci <da...@google.com>
Committed: Tue Nov 1 12:52:36 2016 -0700

----------------------------------------------------------------------
 .../beam/examples/common/ExampleUtils.java      |   3 +-
 .../dataflow/BlockingDataflowRunner.java        | 170 -----------
 .../dataflow/DataflowJobCancelledException.java |  39 ---
 .../dataflow/DataflowJobExecutionException.java |  35 ---
 .../dataflow/DataflowJobUpdatedException.java   |  51 ----
 .../runners/dataflow/DataflowPipelineJob.java   |  43 ++-
 .../dataflow/DataflowPipelineRegistrar.java     |  11 +-
 .../BlockingDataflowPipelineOptions.java        |  28 --
 .../testing/TestDataflowPipelineOptions.java    |   6 +-
 .../dataflow/testing/TestDataflowRunner.java    |   7 +-
 .../dataflow/BlockingDataflowRunnerTest.java    | 300 -------------------
 .../dataflow/DataflowPipelineJobTest.java       |  30 +-
 .../dataflow/DataflowPipelineRegistrarTest.java |   7 +-
 .../apache/beam/sdk/transforms/Aggregator.java  |   9 +-
 14 files changed, 80 insertions(+), 659 deletions(-)
----------------------------------------------------------------------