Remove the explicit types

apache · Dec 12, 2014 · 48ee7b9 · 48ee7b9
1 parent 95d59d6
commit 48ee7b9
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/core/src/main/scala/org/apache/spark/rdd/PairRDDFunctions.scala b/core/src/main/scala/org/apache/spark/rdd/PairRDDFunctions.scala
@@ -493,7 +493,7 @@ class PairRDDFunctions[K, V](self: RDD[(K, V)])
   def leftOuterJoin[W](other: RDD[(K, W)], partitioner: Partitioner): RDD[(K, (V, Option[W]))] = {
     this.cogroup(other, partitioner).flatMapValues { pair =>
       if (pair._2.isEmpty) {
-        pair._1.iterator.map(v => (v, None): (V, Option[W]))
+        pair._1.iterator.map(v => (v, None))
       } else {
         for (v <- pair._1.iterator; w <- pair._2.iterator) yield (v, Some(w))
       }
@@ -510,7 +510,7 @@ class PairRDDFunctions[K, V](self: RDD[(K, V)])
       : RDD[(K, (Option[V], W))] = {
     this.cogroup(other, partitioner).flatMapValues { pair =>
       if (pair._1.isEmpty) {
-        pair._2.iterator.map(w => (None, w): (Option[V], W))
+        pair._2.iterator.map(w => (None, w))
       } else {
         for (v <- pair._1.iterator; w <- pair._2.iterator) yield (Some(v), w)
       }
@@ -528,8 +528,8 @@ class PairRDDFunctions[K, V](self: RDD[(K, V)])
   def fullOuterJoin[W](other: RDD[(K, W)], partitioner: Partitioner)
       : RDD[(K, (Option[V], Option[W]))] = {
     this.cogroup(other, partitioner).flatMapValues {
-      case (vs, Seq()) => vs.iterator.map(v => (Some(v), None): (Option[V], Option[W]))
-      case (Seq(), ws) => ws.iterator.map(w => (None, Some(w)): (Option[V], Option[W]))
+      case (vs, Seq()) => vs.iterator.map(v => (Some(v), None))
+      case (Seq(), ws) => ws.iterator.map(w => (None, Some(w)))
       case (vs, ws) => for (v <- vs.iterator; w <- ws.iterator) yield (Some(v), Some(w))
     }
   }