-
- Downloads
Update default.parallelism docs, have StandaloneSchedulerBackend use it.
Only brand new RDDs (e.g. parallelize and makeRDD) now use default parallelism, everything else uses their largest parent's partitioner or partition size.
Showing
- core/FileServerSuite.txt 1 addition, 0 deletionscore/FileServerSuite.txt
- core/src/main/scala/spark/PairRDDFunctions.scala 1 addition, 15 deletionscore/src/main/scala/spark/PairRDDFunctions.scala
- core/src/main/scala/spark/Partitioner.scala 19 additions, 0 deletionscore/src/main/scala/spark/Partitioner.scala
- core/src/main/scala/spark/RDD.scala 14 additions, 6 deletionscore/src/main/scala/spark/RDD.scala
- core/src/main/scala/spark/SparkContext.scala 1 addition, 1 deletioncore/src/main/scala/spark/SparkContext.scala
- core/src/main/scala/spark/api/java/JavaPairRDD.scala 1 addition, 1 deletioncore/src/main/scala/spark/api/java/JavaPairRDD.scala
- core/src/main/scala/spark/scheduler/cluster/StandaloneSchedulerBackend.scala 2 additions, 1 deletion.../spark/scheduler/cluster/StandaloneSchedulerBackend.scala
- docs/tuning.md 4 additions, 4 deletionsdocs/tuning.md
Loading
Please register or sign in to comment