diff options
| author | Ali Ghodsi <alig@cs.berkeley.edu> | 2013-08-20 13:59:48 -0700 |
|---|---|---|
| committer | Ali Ghodsi <alig@cs.berkeley.edu> | 2013-08-20 16:16:05 -0700 |
| commit | 5cd21c41950e3004d3326bbc56286285531063f9 (patch) | |
| tree | 5be7867f892c4db8a9981e69fbb6d0d855db66b9 /core | |
| parent | db4bc55bef47aaac85c280d5c7d0d82217101b84 (diff) | |
| download | spark-5cd21c41950e3004d3326bbc56286285531063f9.tar.gz spark-5cd21c41950e3004d3326bbc56286285531063f9.tar.bz2 spark-5cd21c41950e3004d3326bbc56286285531063f9.zip | |
added curly braces to make the code more consistent
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/SparkContext.scala | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/SparkContext.scala b/core/src/main/scala/spark/SparkContext.scala index 7639749ecb..a8cc4f3eb8 100644 --- a/core/src/main/scala/spark/SparkContext.scala +++ b/core/src/main/scala/spark/SparkContext.scala @@ -620,8 +620,9 @@ class SparkContext( * @param partition to be looked up for locality * @return list of preferred locations for the partition */ - private [spark] def getPreferredLocs(rdd: RDD[_], partition: Int): List[String] = + private [spark] def getPreferredLocs(rdd: RDD[_], partition: Int): List[String] = { dagScheduler.getPreferredLocs(rdd, partition) + } /** * Adds a JAR dependency for all tasks to be executed on this SparkContext in the future. |