From 078d4101f56c68c6f191de57f9e542a80f2c89b5 Mon Sep 17 00:00:00 2001 From: zhangjiajin Date: Tue, 14 Jul 2015 10:46:05 +0800 Subject: [PATCH] fix a scala style error. --- .../src/main/scala/org/apache/spark/mllib/fpm/PrefixSpan.scala | 2 +- 1 file changed, 1 insertion(+), 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 index 82d864b44fa6e..33e381e6d4d66 100644 --- 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))