This is an automated email from the ASF dual-hosted git repository.
aromanenko pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 4fd73625660a4c27cf36c6d639cba5c6e5644d15
Merge: cceac3b55d9 b4d6b6652bf
Author: Alexey Romanenko <33895511+aromanenko-...@users.noreply.github.com>
AuthorDate: Tue Dec 6 11:28:52 2022 +0100
Merge pull request #24523: [Spark Dataset runner] Broadcast pipeline options
.../io/BoundedDatasetFactory.java | 10 +++---
.../translation/PipelineTranslator.java | 39 +++++++++++++++++++---
.../translation/SparkSessionFactory.java | 5 +++
.../translation/TransformTranslator.java | 9 ++---
.../batch/DoFnMapPartitionsFactory.java | 7 ++--
.../batch/GroupByKeyTranslatorBatch.java | 2 +-
.../translation/batch/ParDoTranslatorBatch.java | 2 +-
.../batch/ReadSourceTranslatorBatch.java | 5 +--
.../GroupAlsoByWindowViaOutputBufferFn.java | 7 ++--
9 files changed, 62 insertions(+), 24 deletions(-)
