This closes #2446
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fc100650 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/fc100650 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/fc100650 Branch: refs/heads/master Commit: fc1006500d14afd01a3a34527c0ea9dc94ac09e9 Parents: 836e8e4 33d4a02 Author: Chamikara Jayalath <chamik...@google.com> Authored: Mon Apr 10 14:18:30 2017 -0700 Committer: Chamikara Jayalath <chamik...@google.com> Committed: Mon Apr 10 14:18:30 2017 -0700 ---------------------------------------------------------------------- sdks/python/apache_beam/internal/pickler.py | 22 ++-- sdks/python/apache_beam/pipeline.py | 4 +- sdks/python/apache_beam/pipeline_test.py | 13 +- .../runners/dataflow/dataflow_runner.py | 24 ---- .../runners/dataflow/dataflow_runner_test.py | 2 +- .../consumer_tracking_pipeline_visitor_test.py | 22 ++-- .../runners/direct/transform_evaluator.py | 31 ----- sdks/python/apache_beam/transforms/core.py | 92 +++++++++++++- .../apache_beam/transforms/create_test.py | 121 +++++++++++++++++++ .../apache_beam/transforms/ptransform_test.py | 14 +-- 10 files changed, 254 insertions(+), 91 deletions(-) ----------------------------------------------------------------------