diff options
| author | Binh Nguyen <ngbinh@gmail.com> | 2013-12-10 01:04:52 -0800 |
|---|---|---|
| committer | Binh Nguyen <ngbinh@gmail.com> | 2013-12-10 01:04:52 -0800 |
| commit | c82d4f079bf84da06801419defe644f574d0b8d1 (patch) | |
| tree | 57242ce0d824823bb85784fc9be237ce00e33e6f | |
| parent | 5013fb64b27e46bbc5daf4f06fdc70938c06cf29 (diff) | |
| download | spark-c82d4f079bf84da06801419defe644f574d0b8d1.tar.gz spark-c82d4f079bf84da06801419defe644f574d0b8d1.tar.bz2 spark-c82d4f079bf84da06801419defe644f574d0b8d1.zip | |
Use braces to shorten the line.
| -rw-r--r-- | core/src/main/scala/org/apache/spark/api/java/JavaPairRDD.scala | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/api/java/JavaPairRDD.scala b/core/src/main/scala/org/apache/spark/api/java/JavaPairRDD.scala index a191dfd1dc..36bd3e673f 100644 --- a/core/src/main/scala/org/apache/spark/api/java/JavaPairRDD.scala +++ b/core/src/main/scala/org/apache/spark/api/java/JavaPairRDD.scala @@ -583,7 +583,9 @@ class JavaPairRDD[K, V](val rdd: RDD[(K, V)])(implicit val kManifest: ClassManif * (in the `save` case, they will be written to multiple `part-X` files in the filesystem, in * order of the keys). */ - def sortByKey(comp: Comparator[K], ascending: Boolean): JavaPairRDD[K, V] = sortByKey(comp, ascending, rdd.partitions.size) + def sortByKey(comp: Comparator[K], ascending: Boolean): JavaPairRDD[K, V] = { + sortByKey(comp, ascending, rdd.partitions.size) + } /** * Sort the RDD by key, so that each partition contains a sorted range of the elements. Calling |