Repository: beam Updated Branches: refs/heads/master a71f00078 -> 77c77add1
Closes #4020 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/77c77add Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/77c77add Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/77c77add Branch: refs/heads/master Commit: 77c77add12fb9b118f4ff1418d7fe5dec5154895 Parents: a71f000 38556b7 Author: Robert Bradshaw <rober...@gmail.com> Authored: Sun Oct 22 00:37:19 2017 -0700 Committer: Robert Bradshaw <rober...@gmail.com> Committed: Sun Oct 22 00:37:19 2017 -0700 ---------------------------------------------------------------------- sdks/python/apache_beam/pipeline.py | 30 ++-- sdks/python/apache_beam/pvalue.py | 103 +++++++++++++- .../runners/direct/transform_evaluator.py | 9 +- .../runners/portability/fn_api_runner.py | 142 +++++++++++++++---- .../runners/portability/fn_api_runner_test.py | 41 +++++- .../runners/worker/bundle_processor.py | 116 +++++++++------ .../apache_beam/runners/worker/data_plane.py | 18 ++- .../apache_beam/runners/worker/operations.pxd | 1 + .../apache_beam/runners/worker/operations.py | 17 ++- .../apache_beam/runners/worker/sdk_worker.py | 111 ++++++++++++++- sdks/python/apache_beam/transforms/core.py | 23 ++- sdks/python/apache_beam/utils/urns.py | 5 + 12 files changed, 511 insertions(+), 105 deletions(-) ----------------------------------------------------------------------
