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

Posted to commits@beam.apache.org by ka...@apache.org on 2020/11/04 22:45:41 UTC

[beam] branch master updated (7dcbdf1 -> dfbeeca)

This is an automated email from the ASF dual-hosted git repository.

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


    from 7dcbdf1  Merge pull request #13249 from Adding display data to BQ File Loads transform
     add dfbeeca  [BEAM-3736] Add CombineFn.setup and CombineFn.teardown to Python SDK (#13048)

No new revisions were added by this update.

Summary of changes:
 CHANGES.md                                         |   1 +
 .../runners/dataflow/dataflow_runner.py            |  40 ++++++-
 .../runners/dataflow/dataflow_runner_test.py       |  19 +++
 .../apache_beam/runners/direct/direct_userstate.py |  16 ++-
 .../runners/direct/helper_transforms.py            |  12 ++
 .../runners/direct/transform_evaluator.py          |   1 +
 .../apache_beam/runners/worker/bundle_processor.py |  13 +-
 .../apache_beam/runners/worker/operations.py       |  30 +++++
 .../transforms/combinefn_lifecycle_pipeline.py     | 131 +++++++++++++++++++++
 .../transforms/combinefn_lifecycle_test.py         |  98 +++++++++++++++
 sdks/python/apache_beam/transforms/combiners.py    |  52 ++++++--
 sdks/python/apache_beam/transforms/core.py         |  52 ++++++--
 sdks/python/apache_beam/transforms/trigger.py      |   2 +
 sdks/python/apache_beam/transforms/userstate.py    |   4 +
 sdks/python/apache_beam/typehints/typecheck.py     |   6 +
 15 files changed, 449 insertions(+), 28 deletions(-)
 create mode 100644 sdks/python/apache_beam/transforms/combinefn_lifecycle_pipeline.py
 create mode 100644 sdks/python/apache_beam/transforms/combinefn_lifecycle_test.py