This is an automated email from the ASF dual-hosted git repository. robertwb pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit f42934b7b5b56176a367b72f2e7baab83e50db58 Merge: d6dc360 ac3e485 Author: Robert Bradshaw <[email protected]> AuthorDate: Tue Sep 18 09:43:04 2018 +0200 Merge pull request #6405 [BEAM-5395] Chunk data streams. [BEAM-5395] Chunk data streams. sdks/python/apache_beam/coders/slow_stream.py | 9 ++++++- sdks/python/apache_beam/coders/stream.pxd | 1 + sdks/python/apache_beam/coders/stream.pyx | 3 +++ .../runners/portability/fn_api_runner.py | 12 +++++++-- .../runners/portability/fn_api_runner_test.py | 20 +++++++++++++++ .../apache_beam/runners/worker/bundle_processor.py | 1 + .../apache_beam/runners/worker/data_plane.py | 29 ++++++++++++++++------ 7 files changed, 65 insertions(+), 10 deletions(-)
