beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From m..@apache.org
Subject [beam] branch master updated (de9b5b6 -> c1007b6)
Date Tue, 01 Oct 2019 11:34:34 GMT
This is an automated email from the ASF dual-hosted git repository.

mxm pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from de9b5b6  Merge pull request #9698: [BEAM-8021] Swap build-tools to be compile only
so it isn't a "required" dependency of Flink.
     add 0128ceb  [BEAM-5428] Implement cross-bundle user state caching in the Python SDK
     add 55588e9  [BEAM-5428] Add pipeline option to enable caching / Disable caching by default
     add c1007b6  Merge pull request #9418: [BEAM-5428] Implement cross-bundle user state
caching in the Python SDK

No new revisions were added by this update.

Summary of changes:
 sdks/python/apache_beam/portability/python_urns.py |   4 +-
 .../runners/portability/fn_api_runner.py           | 126 +++++++++++----
 .../runners/portability/fn_api_runner_test.py      |  13 +-
 .../runners/portability/portable_runner.py         |   1 +
 .../runners/portability/portable_runner_test.py    |   8 +-
 .../apache_beam/runners/worker/bundle_processor.py |  70 ++++-----
 .../apache_beam/runners/worker/sdk_worker.py       | 173 +++++++++++++++++----
 .../apache_beam/runners/worker/sdk_worker_main.py  |  23 +++
 .../apache_beam/runners/worker/sdk_worker_test.py  |   3 +-
 .../apache_beam/runners/worker/statecache.py       | 122 +++++++++++++++
 .../apache_beam/runners/worker/statecache_test.py  | 155 ++++++++++++++++++
 .../apache_beam/runners/worker/worker_pool_main.py |  29 +++-
 12 files changed, 622 insertions(+), 105 deletions(-)
 create mode 100644 sdks/python/apache_beam/runners/worker/statecache.py
 create mode 100644 sdks/python/apache_beam/runners/worker/statecache_test.py


Mime
View raw message