This closes #3349
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c12d6ba8 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c12d6ba8 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/c12d6ba8 Branch: refs/heads/master Commit: c12d6ba8092f3a140747c09bbf6fab8399bcba20 Parents: 2ab482d bcd4396 Author: chamik...@google.com <chamik...@google.com> Authored: Mon Jun 19 10:22:04 2017 -0700 Committer: chamik...@google.com <chamik...@google.com> Committed: Mon Jun 19 10:22:04 2017 -0700 ---------------------------------------------------------------------- .../runners/dataflow/dataflow_runner.py | 34 +++++++++ .../runners/dataflow/dataflow_runner_test.py | 18 +++++ .../dataflow/native_io/streaming_create.py | 72 ++++++++++++++++++++ .../runners/dataflow/ptransform_overrides.py | 52 ++++++++++++++ sdks/python/apache_beam/transforms/core.py | 11 +-- 5 files changed, 183 insertions(+), 4 deletions(-) ----------------------------------------------------------------------
