You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2017/04/21 17:53:27 UTC
[43/50] [abbrv] beam git commit: [BEAM-1956] Modify types for input
PCollections of Flatten transform
[BEAM-1956] Modify types for input PCollections of Flatten transform
This closes #2543
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6224556b
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6224556b
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/6224556b
Branch: refs/heads/gearpump-runner
Commit: 6224556be13c94758f327492bd2bd0b1d6a4432e
Parents: 1721cea 8c88d6a
Author: Luke Cwik <lc...@google.com>
Authored: Wed Apr 19 15:36:11 2017 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Wed Apr 19 15:36:11 2017 -0700
----------------------------------------------------------------------
.../runners/dataflow/dataflow_runner.py | 68 ++++++++++++++++++++
.../runners/dataflow/dataflow_runner_test.py | 65 ++++++++++++++++++-
.../apache_beam/runners/direct/direct_runner.py | 2 -
sdks/python/apache_beam/runners/runner.py | 41 ------------
sdks/python/apache_beam/runners/runner_test.py | 41 ------------
sdks/python/apache_beam/utils/proto_utils.py | 2 +-
6 files changed, 133 insertions(+), 86 deletions(-)
----------------------------------------------------------------------