This is an automated email from the ASF dual-hosted git repository.
ccy pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 19a0a5f [BEAM-5267] Make Flink Runner compile compatible with Flink
1.6.0 (#6331)
add efce3fa [BEAM-5264] Reference DirectRunner implementation of Python
User State and Timers API
add 692238f Address review comments
add ee958b1 Address additional comments
add bf6f8fc Address more comments
add fef40fc Merge pull request #6304 from
charlesccychen/direct-runner-state-timers-2
No new revisions were added by this update.
Summary of changes:
sdks/python/apache_beam/runners/common.pxd | 6 +
sdks/python/apache_beam/runners/common.py | 105 +++++++-
.../apache_beam/runners/direct/direct_runner.py | 3 +
.../apache_beam/runners/direct/direct_userstate.py | 110 ++++++++
.../runners/direct/transform_evaluator.py | 71 ++++--
sdks/python/apache_beam/transforms/core.py | 24 +-
sdks/python/apache_beam/transforms/userstate.py | 250 +++++++++++++++----
.../apache_beam/transforms/userstate_test.py | 277 ++++++++++++++++++++-
8 files changed, 754 insertions(+), 92 deletions(-)
create mode 100644 sdks/python/apache_beam/runners/direct/direct_userstate.py
