-
- Downloads
Merge pull request #401 from andrewor14/master
External sorting - Add number of bytes spilled to Web UI Additionally, update test suite for external sorting to induce spilling.
No related branches found
No related tags found
Showing
- core/src/main/scala/org/apache/spark/Aggregator.scala 8 additions, 4 deletionscore/src/main/scala/org/apache/spark/Aggregator.scala
- core/src/main/scala/org/apache/spark/executor/Executor.scala 1 addition, 1 deletioncore/src/main/scala/org/apache/spark/executor/Executor.scala
- core/src/main/scala/org/apache/spark/executor/TaskMetrics.scala 10 additions, 0 deletions...rc/main/scala/org/apache/spark/executor/TaskMetrics.scala
- core/src/main/scala/org/apache/spark/rdd/CoGroupedRDD.scala 3 additions, 0 deletionscore/src/main/scala/org/apache/spark/rdd/CoGroupedRDD.scala
- core/src/main/scala/org/apache/spark/rdd/PairRDDFunctions.scala 6 additions, 4 deletions...rc/main/scala/org/apache/spark/rdd/PairRDDFunctions.scala
- core/src/main/scala/org/apache/spark/ui/jobs/ExecutorSummary.scala 2 additions, 0 deletions...main/scala/org/apache/spark/ui/jobs/ExecutorSummary.scala
- core/src/main/scala/org/apache/spark/ui/jobs/ExecutorTable.scala 4 additions, 0 deletions...c/main/scala/org/apache/spark/ui/jobs/ExecutorTable.scala
- core/src/main/scala/org/apache/spark/ui/jobs/JobProgressListener.scala 14 additions, 0 deletions.../scala/org/apache/spark/ui/jobs/JobProgressListener.scala
- core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala 49 additions, 4 deletionscore/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala
- core/src/main/scala/org/apache/spark/util/collection/ExternalAppendOnlyMap.scala 10 additions, 1 deletion.../apache/spark/util/collection/ExternalAppendOnlyMap.scala
- core/src/test/scala/org/apache/spark/util/collection/ExternalAppendOnlyMapSuite.scala 44 additions, 33 deletions...he/spark/util/collection/ExternalAppendOnlyMapSuite.scala
Loading
Please register or sign in to comment