-
- Downloads
[SPARK-12884] Move classes to their own files for readability
This is a small step in implementing SPARK-10620, which migrates `TaskMetrics` to accumulators. This patch is strictly a cleanup patch and introduces no change in functionality. It literally just moves classes to their own files to avoid having single monolithic ones that contain 10 different classes. Parent PR: #10717 Author: Andrew Or <andrew@databricks.com> Closes #10810 from andrewor14/move-things.
Showing
- core/src/main/scala/org/apache/spark/Accumulable.scala 3 additions, 176 deletionscore/src/main/scala/org/apache/spark/Accumulable.scala
- core/src/main/scala/org/apache/spark/Accumulator.scala 160 additions, 0 deletionscore/src/main/scala/org/apache/spark/Accumulator.scala
- core/src/main/scala/org/apache/spark/InternalAccumulator.scala 58 additions, 0 deletions...src/main/scala/org/apache/spark/InternalAccumulator.scala
- core/src/main/scala/org/apache/spark/executor/InputMetrics.scala 77 additions, 0 deletions...c/main/scala/org/apache/spark/executor/InputMetrics.scala
- core/src/main/scala/org/apache/spark/executor/OutputMetrics.scala 53 additions, 0 deletions.../main/scala/org/apache/spark/executor/OutputMetrics.scala
- core/src/main/scala/org/apache/spark/executor/ShuffleReadMetrics.scala 87 additions, 0 deletions.../scala/org/apache/spark/executor/ShuffleReadMetrics.scala
- core/src/main/scala/org/apache/spark/executor/ShuffleWriteMetrics.scala 53 additions, 0 deletions...scala/org/apache/spark/executor/ShuffleWriteMetrics.scala
- core/src/main/scala/org/apache/spark/executor/TaskMetrics.scala 2 additions, 184 deletions...rc/main/scala/org/apache/spark/executor/TaskMetrics.scala
Loading
Please register or sign in to comment