diff options
| author | Ali Ghodsi <alig@cs.berkeley.edu> | 2013-08-20 12:17:55 -0700 |
|---|---|---|
| committer | Ali Ghodsi <alig@cs.berkeley.edu> | 2013-08-20 16:16:05 -0700 |
| commit | db4bc55bef47aaac85c280d5c7d0d82217101b84 (patch) | |
| tree | 877635a47ec8964a220a93ceed356849b97f7317 /core | |
| parent | c0942a710f25c9c690761b0814a07deacd4df595 (diff) | |
| download | spark-db4bc55bef47aaac85c280d5c7d0d82217101b84.tar.gz spark-db4bc55bef47aaac85c280d5c7d0d82217101b84.tar.bz2 spark-db4bc55bef47aaac85c280d5c7d0d82217101b84.zip | |
indent
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/rdd/CoalescedRDD.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/rdd/CoalescedRDD.scala b/core/src/main/scala/spark/rdd/CoalescedRDD.scala index b83d443de3..f880cea2ad 100644 --- a/core/src/main/scala/spark/rdd/CoalescedRDD.scala +++ b/core/src/main/scala/spark/rdd/CoalescedRDD.scala @@ -260,7 +260,7 @@ private[spark] class PartitionCoalescer(maxPartitions: Int, prev: RDD[_], balanc } while (numCreated < targetLen) { // if we don't have enough partition groups, create duplicates - var (nxt_replica, nxt_part) = rotIt.next() + var (nxt_replica, nxt_part) = rotIt.next() val pgroup = PartitionGroup(nxt_replica) groupArr += pgroup groupHash.get(nxt_replica).get += pgroup |