-
- Downloads
Miscellaneous fixes from code review.
Also replaced SparkConf.getOrElse with just a "get" that takes a default value, and added getInt, getLong, etc to make code that uses this simpler later on.
Showing
- core/src/main/scala/org/apache/spark/SparkConf.scala 37 additions, 23 deletionscore/src/main/scala/org/apache/spark/SparkConf.scala
- core/src/main/scala/org/apache/spark/SparkContext.scala 45 additions, 28 deletionscore/src/main/scala/org/apache/spark/SparkContext.scala
- core/src/main/scala/org/apache/spark/SparkEnv.scala 5 additions, 5 deletionscore/src/main/scala/org/apache/spark/SparkEnv.scala
- core/src/main/scala/org/apache/spark/api/python/PythonRDD.scala 2 additions, 2 deletions...rc/main/scala/org/apache/spark/api/python/PythonRDD.scala
- core/src/main/scala/org/apache/spark/broadcast/Broadcast.scala 2 additions, 2 deletions...src/main/scala/org/apache/spark/broadcast/Broadcast.scala
- core/src/main/scala/org/apache/spark/broadcast/HttpBroadcast.scala 2 additions, 2 deletions...main/scala/org/apache/spark/broadcast/HttpBroadcast.scala
- core/src/main/scala/org/apache/spark/broadcast/TorrentBroadcast.scala 1 addition, 1 deletion...n/scala/org/apache/spark/broadcast/TorrentBroadcast.scala
- core/src/main/scala/org/apache/spark/deploy/master/Master.scala 6 additions, 6 deletions...rc/main/scala/org/apache/spark/deploy/master/Master.scala
- core/src/main/scala/org/apache/spark/deploy/master/MasterArguments.scala 3 additions, 3 deletions...cala/org/apache/spark/deploy/master/MasterArguments.scala
- core/src/main/scala/org/apache/spark/deploy/master/SparkZooKeeperSession.scala 1 addition, 1 deletion...rg/apache/spark/deploy/master/SparkZooKeeperSession.scala
- core/src/main/scala/org/apache/spark/deploy/master/ZooKeeperLeaderElectionAgent.scala 1 addition, 1 deletion...he/spark/deploy/master/ZooKeeperLeaderElectionAgent.scala
- core/src/main/scala/org/apache/spark/deploy/master/ZooKeeperPersistenceEngine.scala 1 addition, 1 deletion...ache/spark/deploy/master/ZooKeeperPersistenceEngine.scala
- core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala 1 addition, 1 deletion...rc/main/scala/org/apache/spark/deploy/worker/Worker.scala
- core/src/main/scala/org/apache/spark/deploy/worker/ui/WorkerWebUI.scala 1 addition, 1 deletion...scala/org/apache/spark/deploy/worker/ui/WorkerWebUI.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/io/CompressionCodec.scala 2 additions, 2 deletions...src/main/scala/org/apache/spark/io/CompressionCodec.scala
- core/src/main/scala/org/apache/spark/metrics/MetricsSystem.scala 1 addition, 1 deletion...c/main/scala/org/apache/spark/metrics/MetricsSystem.scala
- core/src/main/scala/org/apache/spark/network/ConnectionManager.scala 9 additions, 9 deletions...in/scala/org/apache/spark/network/ConnectionManager.scala
- core/src/main/scala/org/apache/spark/network/netty/ShuffleCopier.scala 1 addition, 1 deletion.../scala/org/apache/spark/network/netty/ShuffleCopier.scala
- core/src/main/scala/org/apache/spark/rdd/CheckpointRDD.scala 2 additions, 2 deletionscore/src/main/scala/org/apache/spark/rdd/CheckpointRDD.scala
Loading
Please register or sign in to comment