-
- Downloads
[SPARK-15049] Rename NewAccumulator to AccumulatorV2
## What changes were proposed in this pull request? NewAccumulator isn't the best name if we ever come up with v3 of the API. ## How was this patch tested? Updated tests to reflect the change. Author: Reynold Xin <rxin@databricks.com> Closes #12827 from rxin/SPARK-15049.
Showing
- core/src/main/scala/org/apache/spark/AccumulatorV2.scala 35 additions, 34 deletionscore/src/main/scala/org/apache/spark/AccumulatorV2.scala
- core/src/main/scala/org/apache/spark/ContextCleaner.scala 1 addition, 1 deletioncore/src/main/scala/org/apache/spark/ContextCleaner.scala
- core/src/main/scala/org/apache/spark/HeartbeatReceiver.scala 1 addition, 1 deletioncore/src/main/scala/org/apache/spark/HeartbeatReceiver.scala
- core/src/main/scala/org/apache/spark/SparkContext.scala 2 additions, 2 deletionscore/src/main/scala/org/apache/spark/SparkContext.scala
- core/src/main/scala/org/apache/spark/TaskContext.scala 1 addition, 1 deletioncore/src/main/scala/org/apache/spark/TaskContext.scala
- core/src/main/scala/org/apache/spark/TaskContextImpl.scala 1 addition, 1 deletioncore/src/main/scala/org/apache/spark/TaskContextImpl.scala
- core/src/main/scala/org/apache/spark/TaskEndReason.scala 2 additions, 2 deletionscore/src/main/scala/org/apache/spark/TaskEndReason.scala
- core/src/main/scala/org/apache/spark/executor/Executor.scala 2 additions, 2 deletionscore/src/main/scala/org/apache/spark/executor/Executor.scala
- core/src/main/scala/org/apache/spark/executor/TaskMetrics.scala 9 additions, 9 deletions...rc/main/scala/org/apache/spark/executor/TaskMetrics.scala
- core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala 5 additions, 5 deletions.../main/scala/org/apache/spark/scheduler/DAGScheduler.scala
- core/src/main/scala/org/apache/spark/scheduler/DAGSchedulerEvent.scala 1 addition, 1 deletion.../scala/org/apache/spark/scheduler/DAGSchedulerEvent.scala
- core/src/main/scala/org/apache/spark/scheduler/Task.scala 1 addition, 1 deletioncore/src/main/scala/org/apache/spark/scheduler/Task.scala
- core/src/main/scala/org/apache/spark/scheduler/TaskResult.scala 4 additions, 4 deletions...rc/main/scala/org/apache/spark/scheduler/TaskResult.scala
- core/src/main/scala/org/apache/spark/scheduler/TaskScheduler.scala 2 additions, 2 deletions...main/scala/org/apache/spark/scheduler/TaskScheduler.scala
- core/src/main/scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala 1 addition, 1 deletion.../scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala
- core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala 1 addition, 1 deletion...ain/scala/org/apache/spark/scheduler/TaskSetManager.scala
- core/src/test/scala/org/apache/spark/AccumulatorSuite.scala 1 addition, 1 deletioncore/src/test/scala/org/apache/spark/AccumulatorSuite.scala
- core/src/test/scala/org/apache/spark/InternalAccumulatorSuite.scala 1 addition, 1 deletion...est/scala/org/apache/spark/InternalAccumulatorSuite.scala
- core/src/test/scala/org/apache/spark/executor/TaskMetricsSuite.scala 3 additions, 3 deletions...st/scala/org/apache/spark/executor/TaskMetricsSuite.scala
- core/src/test/scala/org/apache/spark/scheduler/DAGSchedulerSuite.scala 3 additions, 3 deletions.../scala/org/apache/spark/scheduler/DAGSchedulerSuite.scala
Loading
Please register or sign in to comment