This closes #3318
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c9620834 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c9620834 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/c9620834 Branch: refs/heads/master Commit: c96208347c662b3981ca2b622cad92637d4df3a2 Parents: dd9abc3 0b600d2 Author: Ahmet Altay <[email protected]> Authored: Wed Jun 14 16:47:23 2017 -0700 Committer: Ahmet Altay <[email protected]> Committed: Wed Jun 14 16:47:23 2017 -0700 ---------------------------------------------------------------------- .../apache_beam/options/pipeline_options.py | 9 -- .../apache_beam/runners/direct/direct_runner.py | 28 ++++++ sdks/python/apache_beam/transforms/core.py | 89 +++++++++++--------- 3 files changed, 79 insertions(+), 47 deletions(-) ----------------------------------------------------------------------
