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

Posted to commits@beam.apache.org by ro...@apache.org on 2016/10/27 17:28:31 UTC

[43/50] [abbrv] incubator-beam git commit: Closes #1160

Closes #1160


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

Branch: refs/heads/python-sdk
Commit: 48fdd06760ded8bb2010b12fad430068a06bdec6
Parents: 09a80ec 1559a7f
Author: Dan Halperin <dh...@google.com>
Authored: Wed Oct 26 14:47:10 2016 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Wed Oct 26 14:47:10 2016 -0700

----------------------------------------------------------------------
 .../apache/beam/runners/direct/DirectRunner.java   |  2 +-
 .../runners/dataflow/BlockingDataflowRunner.java   | 13 +------------
 .../beam/runners/dataflow/DataflowPipelineJob.java | 17 +++++++++++++----
 .../spark/translation/EvaluationContext.java       |  6 ++----
 .../streaming/StreamingEvaluationContext.java      |  6 ++----
 .../java/org/apache/beam/sdk/PipelineResult.java   | 10 ++--------
 6 files changed, 21 insertions(+), 33 deletions(-)
----------------------------------------------------------------------