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/04/21 14:05:46 UTC

[beam] 01/01: Merge pull request #17407: [BEAM-14335] Spotless Spark sources

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 839ff5749c72d5ee9e56b3b9a224e16d86a3a9b0
Merge: d38c2d77e7f 49a8da27f24
Author: Alexey Romanenko <33...@users.noreply.github.com>
AuthorDate: Thu Apr 21 16:05:38 2022 +0200

    Merge pull request #17407: [BEAM-14335] Spotless Spark sources

 .../Constants.java => build.gradle}                | 24 +++++++----
 .../spark/stateful/SparkTimerInternals.java        |  3 +-
 .../spark/structuredstreaming/Constants.java       |  1 -
 .../translation/AbstractTranslationContext.java    | 49 +++++++++++-----------
 .../CreatePCollectionViewTranslatorBatch.java      |  3 +-
 .../translation/batch/FlattenTranslatorBatch.java  |  3 +-
 .../translation/batch/ParDoTranslatorBatch.java    |  3 +-
 .../batch/ReadSourceTranslatorBatch.java           |  3 +-
 .../batch/ReshuffleTranslatorBatch.java            |  3 +-
 .../streaming/ReadSourceTranslatorStreaming.java   |  4 +-
 .../GroupNonMergingWindowsFunctions.java           | 29 ++++++++-----
 .../SparkBatchPortablePipelineTranslator.java      |  6 +--
 .../translation/SparkExecutableStageFunction.java  | 24 ++++-------
 .../SparkStreamingPortablePipelineTranslator.java  |  1 -
 .../spark/translation/TransformTranslator.java     |  5 ++-
 .../runners/spark/GlobalWatermarkHolderTest.java   |  4 +-
 .../metrics/sink/SparkMetricsSinkTest.java         |  3 +-
 .../spark/translation/TransformTranslatorTest.java |  6 ++-
 .../translation/streaming/CreateStreamTest.java    | 10 +++--
 19 files changed, 96 insertions(+), 88 deletions(-)