Skip to content

Commit 98c44d0

Browse files
committed
[SPARK-51985][CORE] Remove Experimental from (Long|Double)AccumulatorSource
### What changes were proposed in this pull request? This PR aims to remove `Experimental` tag from `LongAccumulatorSource` and `DoubleAccumulatorSource`. ### Why are the changes needed? These are added at Apache Spark 3.0.0 and have been used without modifications for 7 years (2018-12-22). We can remove `Experimental` at Apache Spark 4.0.0. - #23242 ### Does this PR introduce _any_ user-facing change? No. ### How was this patch tested? Pass the CIs. ### Was this patch authored or co-authored using generative AI tooling? No. Closes #50781 from dongjoon-hyun/SPARK-51985. Authored-by: Dongjoon Hyun <[email protected]> Signed-off-by: Dongjoon Hyun <[email protected]>
1 parent fd56ef6 commit 98c44d0

File tree

1 file changed

+0
-7
lines changed

1 file changed

+0
-7
lines changed

core/src/main/scala/org/apache/spark/metrics/source/AccumulatorSource.scala

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,6 @@ package org.apache.spark.metrics.source
2020
import com.codahale.metrics.{Gauge, MetricRegistry}
2121

2222
import org.apache.spark.SparkContext
23-
import org.apache.spark.annotation.Experimental
2423
import org.apache.spark.util.{AccumulatorV2, DoubleAccumulator, LongAccumulator}
2524

2625
/**
@@ -48,21 +47,17 @@ private[spark] class AccumulatorSource extends Source {
4847
override def metricRegistry: MetricRegistry = registry
4948
}
5049

51-
@Experimental
5250
class LongAccumulatorSource extends AccumulatorSource
5351

54-
@Experimental
5552
class DoubleAccumulatorSource extends AccumulatorSource
5653

5754
/**
58-
* :: Experimental ::
5955
* Metrics source specifically for LongAccumulators. Accumulators
6056
* are only valid on the driver side, so these metrics are reported
6157
* only by the driver.
6258
* Register LongAccumulators using:
6359
* LongAccumulatorSource.register(sc, {"name" -> longAccumulator})
6460
*/
65-
@Experimental
6661
object LongAccumulatorSource {
6762
def register(sc: SparkContext, accumulators: Map[String, LongAccumulator]): Unit = {
6863
val source = new LongAccumulatorSource
@@ -72,14 +67,12 @@ object LongAccumulatorSource {
7267
}
7368

7469
/**
75-
* :: Experimental ::
7670
* Metrics source specifically for DoubleAccumulators. Accumulators
7771
* are only valid on the driver side, so these metrics are reported
7872
* only by the driver.
7973
* Register DoubleAccumulators using:
8074
* DoubleAccumulatorSource.register(sc, {"name" -> doubleAccumulator})
8175
*/
82-
@Experimental
8376
object DoubleAccumulatorSource {
8477
def register(sc: SparkContext, accumulators: Map[String, DoubleAccumulator]): Unit = {
8578
val source = new DoubleAccumulatorSource

0 commit comments

Comments
 (0)