Repository: beam Updated Branches: refs/heads/master 9e6530adb -> 72bd73ab3
Closes #3682 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/72bd73ab Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/72bd73ab Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/72bd73ab Branch: refs/heads/master Commit: 72bd73ab35a58a9473e8d78054e1c30d0a391508 Parents: 9e6530a 5e71d53 Author: Robert Bradshaw <[email protected]> Authored: Thu Aug 3 23:44:40 2017 -0700 Committer: Robert Bradshaw <[email protected]> Committed: Thu Aug 3 23:44:40 2017 -0700 ---------------------------------------------------------------------- sdks/python/apache_beam/coders/stream.pxd | 2 +- sdks/python/apache_beam/coders/stream.pyx | 2 +- .../apache_beam/runners/pipeline_context.py | 8 +- .../runners/portability/fn_api_runner.py | 569 ++++++++++++++++++- .../runners/portability/fn_api_runner_test.py | 2 +- .../runners/worker/bundle_processor.py | 107 +++- sdks/python/apache_beam/transforms/core.py | 6 +- 7 files changed, 678 insertions(+), 18 deletions(-) ----------------------------------------------------------------------
