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 dad0159c53bb672db589139c2b2bd0d16f384d3e Merge: d07a622 859e5ae Author: Robert Bradshaw <[email protected]> AuthorDate: Thu Sep 20 10:27:14 2018 +0200 Merge pull request #6349 [BEAM-2687] Implement State over the Fn API [BEAM-2687] Implement State over the Fn API sdks/python/apache_beam/runners/common.py | 4 + .../apache_beam/runners/direct/direct_runner.py | 4 +- .../runners/portability/fn_api_runner.py | 13 +- .../runners/portability/fn_api_runner_test.py | 24 ++++ .../apache_beam/runners/worker/bundle_processor.py | 135 ++++++++++++++++++--- .../apache_beam/runners/worker/operations.pxd | 1 + .../apache_beam/runners/worker/operations.py | 5 +- sdks/python/apache_beam/transforms/core.py | 13 +- sdks/python/apache_beam/transforms/timeutil.py | 13 ++ sdks/python/apache_beam/transforms/userstate.py | 22 +++- .../apache_beam/transforms/userstate_test.py | 2 +- 11 files changed, 206 insertions(+), 30 deletions(-)
