You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ch...@apache.org on 2017/04/10 21:19:21 UTC
[2/2] beam git commit: This closes #2446
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 <ch...@google.com>
Authored: Mon Apr 10 14:18:30 2017 -0700
Committer: Chamikara Jayalath <ch...@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(-)
----------------------------------------------------------------------