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 83679216cce2d52dbeb7e837f06ca1d57b31d509
Merge: 59849d6609b 5a60769700d
Author: Alexey Romanenko <33895511+aromanenko-...@users.noreply.github.com>
AuthorDate: Mon Dec 12 15:41:31 2022 +0100
Merge pull request #24380:[Spark RDD runner] Remove obsolete unusable
AggregatorsAccumulator / NamedAggregators
.../beam/runners/spark/SparkPipelineRunner.java | 5 -
.../org/apache/beam/runners/spark/SparkRunner.java | 20 +---
.../apache/beam/runners/spark/TestSparkRunner.java | 2 -
.../spark/aggregators/AggregatorsAccumulator.java | 133 ---------------------
.../spark/aggregators/NamedAggregators.java | 113 -----------------
.../aggregators/NamedAggregatorsAccumulator.java | 63 ----------
.../runners/spark/aggregators/package-info.java | 20 ----
.../runners/spark/metrics/AggregatorMetric.java | 74 ------------
.../spark/metrics/AggregatorMetricSource.java | 49 --------
.../runners/spark/metrics/CompositeSource.java | 45 -------
.../beam/runners/spark/metrics/sink/CsvSink.java | 3 +-
.../runners/spark/metrics/sink/GraphiteSink.java | 3 +-
.../ResumeFromCheckpointStreamingTest.java | 2 -
13 files changed, 5 insertions(+), 527 deletions(-)
