Skip to content

Commit f1ee57b

Browse files
committed
Fixed scala style issues
1 parent d7196f1 commit f1ee57b

File tree

1 file changed

+13
-8
lines changed

1 file changed

+13
-8
lines changed

core/src/main/scala/org/apache/spark/rdd/PairRDDFunctions.scala

Lines changed: 13 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -568,10 +568,12 @@ class PairRDDFunctions[K, V](self: RDD[(K, V)])
568568
}
569569

570570
/**
571-
* For each key k in `this` or `other1` or `other2` or `other3`, return a resulting RDD that contains a
572-
* tuple with the list of values for that key in `this`, `other1`, `other2` and `other3`.
571+
* For each key k in `this` or `other1` or `other2` or `other3`,
572+
* return a resulting RDD that contains a tuple with the list of values
573+
* for that key in `this`, `other1`, `other2` and `other3`.
573574
*/
574-
def cogroup[W1, W2, W3](other1: RDD[(K, W1)], other2: RDD[(K, W2)], other3: RDD[(K, W3)], partitioner: Partitioner)
575+
def cogroup[W1, W2, W3](other1: RDD[(K, W1)], other2: RDD[(K, W2)],
576+
other3: RDD[(K, W3)], partitioner: Partitioner)
575577
: RDD[(K, (Iterable[V], Iterable[W1], Iterable[W2], Iterable[W3]))] = {
576578
if (partitioner.isInstanceOf[HashPartitioner] && keyClass.isArray) {
577579
throw new SparkException("Default partitioner cannot partition array keys.")
@@ -618,8 +620,9 @@ class PairRDDFunctions[K, V](self: RDD[(K, V)])
618620
}
619621

620622
/**
621-
* For each key k in `this` or `other1` or `other2` or `other3`, return a resulting RDD that contains a
622-
* tuple with the list of values for that key in `this`, `other1`, `other2` and `other3`.
623+
* For each key k in `this` or `other1` or `other2` or `other3`,
624+
* return a resulting RDD that contains a tuple with the list of values
625+
* for that key in `this`, `other1`, `other2` and `other3`.
623626
*/
624627
def cogroup[W1, W2, W3](other1: RDD[(K, W1)], other2: RDD[(K, W2)], other3: RDD[(K, W3)])
625628
: RDD[(K, (Iterable[V], Iterable[W1], Iterable[W2], Iterable[W3]))] = {
@@ -661,10 +664,12 @@ class PairRDDFunctions[K, V](self: RDD[(K, V)])
661664
}
662665

663666
/**
664-
* For each key k in `this` or `other1` or `other2` or `other3`, return a resulting RDD that contains a
665-
* tuple with the list of values for that key in `this`, `other1`, `other2` and `other3`.
667+
* For each key k in `this` or `other1` or `other2` or `other3`,
668+
* return a resulting RDD that contains a tuple with the list of values
669+
* for that key in `this`, `other1`, `other2` and `other3`.
666670
*/
667-
def cogroup[W1, W2, W3](other1: RDD[(K, W1)], other2: RDD[(K, W2)], other3: RDD[(K, W3)], numPartitions: Int)
671+
def cogroup[W1, W2, W3](other1: RDD[(K, W1)], other2: RDD[(K, W2)],
672+
other3: RDD[(K, W3)], numPartitions: Int)
668673
: RDD[(K, (Iterable[V], Iterable[W1], Iterable[W2], Iterable[W3]))] = {
669674
cogroup(other1, other2, other3, new HashPartitioner(numPartitions))
670675
}

0 commit comments

Comments
 (0)