fix a scala style error.

prabeesh · Jul 22, 2015 · f06772f · f06772f
1 parent a7e50d4
commit f06772f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/mllib/src/main/scala/org/apache/spark/mllib/fpm/PrefixSpan.scala b/mllib/src/main/scala/org/apache/spark/mllib/fpm/PrefixSpan.scala
@@ -125,7 +125,7 @@ class PrefixSpan private (
   (RDD[(Array[Int], Long)], RDD[(Array[Int], Array[Int])]) = {
     val prefixAndFreqentItemAndCounts = prefixAndProjectedDatabase.flatMap{ x =>
       x._2.distinct.map(y => ((x._1.toSeq, y), 1L))
-    }.reduceByKey(_+_)
+    }.reduceByKey(_ + _)
       .filter(_._2 >= minCount)
     val patternAndCounts = prefixAndFreqentItemAndCounts
       .map(x => (x._1._1.toArray ++ Array(x._1._2), x._2))