Repository: beam Updated Branches: refs/heads/master db3144bf6 -> 22ff898a3
This closes #2379 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/22ff898a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/22ff898a Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/22ff898a Branch: refs/heads/master Commit: 22ff898a363715a99b19a75de416d62915681a23 Parents: db3144b 7efee54 Author: Thomas Groh <[email protected]> Authored: Tue Apr 4 10:08:53 2017 -0700 Committer: Thomas Groh <[email protected]> Committed: Tue Apr 4 10:08:53 2017 -0700 ---------------------------------------------------------------------- .../dataflow/DataflowPipelineTranslator.java | 5 +- .../beam/runners/dataflow/DataflowRunner.java | 169 +++++++++++-------- .../main/java/org/apache/beam/sdk/Pipeline.java | 3 +- 3 files changed, 102 insertions(+), 75 deletions(-) ----------------------------------------------------------------------
