[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 <[email protected]> Authored: Wed Apr 19 15:36:11 2017 -0700 Committer: Luke Cwik <[email protected]> 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(-) ----------------------------------------------------------------------
