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/12 17:15:27 UTC
[beam] branch master updated (83679216cce -> 3f2aecfc5bc)

This is an automated email from the ASF dual-hosted git repository.

aromanenko pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


    from 83679216cce Merge pull request #24380:[Spark RDD runner] Remove obsolete unusable AggregatorsAccumulator / NamedAggregators
     add f0c7f86c990 [Spark Dataset runner] Remove obsolete unusable AggregatorsAccumulator / NamedAggregators from the runner (closes #24379)
     add 3f2aecfc5bc Merge pull request #24381: [Spark Dataset runner] Remove obsolete unusable AggregatorsAccumulator / NamedAggregators

No new revisions were added by this update.

Summary of changes:
 .../SparkStructuredStreamingRunner.java            |  28 ++---
 .../aggregators/AggregatorsAccumulator.java        |  73 -------------
 .../aggregators/NamedAggregators.java              | 113 ---------------------
 .../aggregators/NamedAggregatorsAccumulator.java   |  63 ------------
 .../aggregators/package-info.java                  |  20 ----
 .../metrics/AggregatorMetric.java                  |  74 --------------
 .../metrics/AggregatorMetricSource.java            |  49 ---------
 .../metrics/CompositeSource.java                   |  45 --------
 .../metrics/SparkBeamMetricSource.java             |   4 +-
 .../metrics/sink/CodahaleCsvSink.java              |   3 +-
 .../metrics/sink/CodahaleGraphiteSink.java         |   3 +-
 11 files changed, 10 insertions(+), 465 deletions(-)
 delete mode 100644 runners/spark/3/src/main/java/org/apache/beam/runners/spark/structuredstreaming/aggregators/AggregatorsAccumulator.java
 delete mode 100644 runners/spark/3/src/main/java/org/apache/beam/runners/spark/structuredstreaming/aggregators/NamedAggregators.java
 delete mode 100644 runners/spark/3/src/main/java/org/apache/beam/runners/spark/structuredstreaming/aggregators/NamedAggregatorsAccumulator.java
 delete mode 100644 runners/spark/3/src/main/java/org/apache/beam/runners/spark/structuredstreaming/aggregators/package-info.java
 delete mode 100644 runners/spark/3/src/main/java/org/apache/beam/runners/spark/structuredstreaming/metrics/AggregatorMetric.java
 delete mode 100644 runners/spark/3/src/main/java/org/apache/beam/runners/spark/structuredstreaming/metrics/AggregatorMetricSource.java
 delete mode 100644 runners/spark/3/src/main/java/org/apache/beam/runners/spark/structuredstreaming/metrics/CompositeSource.java