You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by mx...@apache.org on 2019/12/25 12:44:00 UTC

[beam] branch master updated (264b9ad -> 693bc91)

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 264b9ad  Merge pull request #10444: [BEAM-9010] Proper TableRow size calculation via TableRowJsonCoder
     add 1b2d9ae  [BEAM-7949] Add time-based cache threshold support in the data service of the Python SDK harness.
     add bf5b96e  [BEAM-7949] Introduce PeriodicThread for time-based cache threshold support.
     add 693bc91  Merge pull request #10246: [BEAM-7949] Add option for time-based flush in Python data service

No new revisions were added by this update.

Summary of changes:
 .../runners/portability/fn_api_runner.py           |  22 ++-
 .../runners/portability/fn_api_runner_test.py      |   6 +-
 .../runners/portability/portable_runner.py         |   2 +
 .../runners/portability/portable_runner_test.py    |  10 +-
 .../apache_beam/runners/worker/data_plane.py       | 157 +++++++++++++++++----
 .../apache_beam/runners/worker/data_plane_test.py  |  44 ++++--
 .../apache_beam/runners/worker/sdk_worker.py       |   6 +-
 .../apache_beam/runners/worker/sdk_worker_main.py  |  28 +++-
 .../apache_beam/runners/worker/worker_pool_main.py |  17 ++-
 sdks/python/apache_beam/transforms/environments.py |  58 ++++++--
 .../apache_beam/transforms/environments_test.py    |   3 +-
 11 files changed, 284 insertions(+), 69 deletions(-)