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

Posted to commits@beam.apache.org by ar...@apache.org on 2022/12/05 13:08:11 UTC

[beam] 01/01: Merge pull request #24522: [Spark Dataset runner] Add @Experimental and reduce visibility where possible

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 66db2d81811dc26e624f2472415d45e879c076c0
Merge: a9dcf95453d c197579e9f2
Author: Alexey Romanenko <33...@users.noreply.github.com>
AuthorDate: Mon Dec 5 14:08:01 2022 +0100

    Merge pull request #24522: [Spark Dataset runner] Add @Experimental and reduce visibility where possible

 .../SparkStructuredStreamingPipelineOptions.java                  | 2 ++
 .../spark/structuredstreaming/SparkStructuredStreamingRunner.java | 2 ++
 .../spark/structuredstreaming/translation/batch/Aggregators.java  | 8 +++++---
 .../translation/batch/CombineGloballyTranslatorBatch.java         | 2 +-
 .../translation/batch/CombineGroupedValuesTranslatorBatch.java    | 2 +-
 .../translation/batch/GroupByKeyTranslatorBatch.java              | 4 ++--
 .../translation/batch/ImpulseTranslatorBatch.java                 | 3 +--
 .../translation/batch/ReshuffleTranslatorBatch.java               | 4 ++--
 8 files changed, 16 insertions(+), 11 deletions(-)