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

Posted to commits@beam.apache.org by pa...@apache.org on 2020/01/28 20:07:21 UTC

[beam] branch master updated (e670b8a -> 302e4d9)

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

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


    from e670b8a  Merge pull request #10592: [BEAM-7746] Introduce a protocol to handle various types of partitioning buffers
     add 302e4d9  Merge pull request #10346 from [BEAM-7926] Data-centric Interactive Part2

No new revisions were added by this update.

Summary of changes:
 .../runners/interactive/interactive_environment.py |  23 +++
 .../runners/interactive/interactive_runner.py      |  18 +-
 .../runners/interactive/interactive_runner_test.py |  33 +++
 .../runners/interactive/pipeline_fragment.py       | 225 +++++++++++++++++++++
 .../runners/interactive/pipeline_fragment_test.py  | 125 ++++++++++++
 .../runners/interactive/pipeline_instrument.py     |  26 ++-
 .../interactive/pipeline_instrument_test.py        |   3 +
 7 files changed, 446 insertions(+), 7 deletions(-)
 create mode 100644 sdks/python/apache_beam/runners/interactive/pipeline_fragment.py
 create mode 100644 sdks/python/apache_beam/runners/interactive/pipeline_fragment_test.py