fix a scala style error.

rekhajoshm · Jul 14, 2015 · 078d410 · 078d410
1 parent 22b0ef4
commit 078d410
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))