beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From c..@apache.org
Subject [beam] branch master updated (19a0a5f -> fef40fc)
Date Tue, 18 Sep 2018 16:35:12 GMT
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


Mime
View raw message