Remove missed Tuple2 match in CoGroupedRDD

sryza · sryza · commit b6d9699ecd18 · 2014-07-18T01:23:40.000-07:00
diff --git a/core/src/main/scala/org/apache/spark/rdd/CoGroupedRDD.scala b/core/src/main/scala/org/apache/spark/rdd/CoGroupedRDD.scala
@@ -170,12 +170,12 @@ class CoGroupedRDD[K](@transient var rdds: Seq[RDD[_ <: Product2[K, _]]], part:
 
     val createCombiner: (CoGroupValue => CoGroupCombiner) = value => {
       val newCombiner = Array.fill(numRdds)(new CoGroup)
-      value match { case (v, depNum) => newCombiner(depNum) += v }
+      newCombiner(value._2) += value._1
       newCombiner
     }
     val mergeValue: (CoGroupCombiner, CoGroupValue) => CoGroupCombiner =
       (combiner, value) => {
-      value match { case (v, depNum) => combiner(depNum) += v }
+      combiner(value._2) += value._1
       combiner
     }
     val mergeCombiners: (CoGroupCombiner, CoGroupCombiner) => CoGroupCombiner =

Original file line number	Diff line number	Diff line change
`@@ -170,12 +170,12 @@ class CoGroupedRDD[K](@transient var rdds: Seq[RDD[_ <: Product2[K, _]]], part:`
`170`	`170`
`171`	`171`	`val createCombiner: (CoGroupValue => CoGroupCombiner) = value => {`
`172`	`172`	`val newCombiner = Array.fill(numRdds)(new CoGroup)`
`173`		`- value match { case (v, depNum) => newCombiner(depNum) += v }`
	`173`	`+ newCombiner(value._2) += value._1`
`174`	`174`	`newCombiner`
`175`	`175`	`}`
`176`	`176`	`val mergeValue: (CoGroupCombiner, CoGroupValue) => CoGroupCombiner =`
`177`	`177`	`(combiner, value) => {`
`178`		`- value match { case (v, depNum) => combiner(depNum) += v }`
	`178`	`+ combiner(value._2) += value._1`
`179`	`179`	`combiner`
`180`	`180`	`}`
`181`	`181`	`val mergeCombiners: (CoGroupCombiner, CoGroupCombiner) => CoGroupCombiner =`