Repository: incubator-beam Updated Branches: refs/heads/master 1df6f5f97 -> 119da4a82
Closes #642 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/119da4a8 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/119da4a8 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/119da4a8 Branch: refs/heads/master Commit: 119da4a82611662486f57536168443277c926790 Parents: 1df6f5f 1b4b7c7 Author: Dan Halperin <[email protected]> Authored: Thu Jul 28 20:00:27 2016 -0700 Committer: Dan Halperin <[email protected]> Committed: Thu Jul 28 20:00:27 2016 -0700 ---------------------------------------------------------------------- .../beam/examples/common/ExampleUtils.java | 4 +- .../beam/runners/direct/DirectRunner.java | 18 +++++ .../beam/runners/flink/FlinkRunnerResult.java | 22 ++++- .../dataflow/BlockingDataflowRunner.java | 5 +- .../runners/dataflow/DataflowPipelineJob.java | 85 +++++++++++--------- .../beam/runners/dataflow/DataflowRunner.java | 5 +- .../dataflow/testing/TestDataflowRunner.java | 7 +- .../dataflow/BlockingDataflowRunnerTest.java | 9 +-- .../dataflow/DataflowPipelineJobTest.java | 43 ++++++---- .../testing/TestDataflowRunnerTest.java | 34 ++++---- .../spark/translation/EvaluationContext.java | 21 +++++ .../org/apache/beam/sdk/PipelineResult.java | 38 +++++++++ .../main/java/common/DataflowExampleUtils.java | 5 +- 13 files changed, 202 insertions(+), 94 deletions(-) ----------------------------------------------------------------------
