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
