This is an automated email from the ASF dual-hosted git repository.
ningk pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 6070500 [BEAM-13821] Add automated expansion service start-up to
KafkaIO (#16716)
add a32a1ea [BEAM-13799] Created a Dataproc cluster manager for
Interactive Beam
No new revisions were added by this update.
Summary of changes:
.../dataproc/dataproc_cluster_manager.py | 164 +++++++++++++++++++++
.../dataproc/dataproc_cluster_manager_test.py | 161 ++++++++++++++++++++
2 files changed, 325 insertions(+)
create mode 100644
sdks/python/apache_beam/runners/interactive/dataproc/dataproc_cluster_manager.py
create mode 100644
sdks/python/apache_beam/runners/interactive/dataproc/dataproc_cluster_manager_test.py
