Repository: beam Updated Branches: refs/heads/master 132d3c5f6 -> affb926cc
Closes #2388 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/affb926c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/affb926c Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/affb926c Branch: refs/heads/master Commit: affb926ccd9302734805d8c0db418d006ee37672 Parents: 132d3c5 207de81 Author: Robert Bradshaw <rober...@gmail.com> Authored: Fri Mar 31 12:11:00 2017 -0700 Committer: Robert Bradshaw <rober...@gmail.com> Committed: Fri Mar 31 12:11:00 2017 -0700 ---------------------------------------------------------------------- sdks/python/apache_beam/pipeline.py | 12 +- sdks/python/apache_beam/pvalue.py | 258 +++++++------------ sdks/python/apache_beam/pvalue_test.py | 33 --- .../runners/dataflow/dataflow_runner.py | 29 ++- .../runners/direct/bundle_factory.py | 3 +- .../consumer_tracking_pipeline_visitor.py | 11 +- .../consumer_tracking_pipeline_visitor_test.py | 4 +- .../runners/direct/evaluation_context.py | 60 +++-- .../apache_beam/runners/direct/executor.py | 7 +- .../runners/direct/transform_evaluator.py | 51 +--- sdks/python/apache_beam/transforms/core.py | 2 +- .../python/apache_beam/transforms/ptransform.py | 4 +- .../python/apache_beam/transforms/sideinputs.py | 132 ---------- .../apache_beam/transforms/sideinputs_test.py | 91 +++---- 14 files changed, 198 insertions(+), 499 deletions(-) ----------------------------------------------------------------------
