Skip to content
This repository was archived by the owner on May 9, 2024. It is now read-only.

Commit 078d410

Browse files
committed
fix a scala style error.
1 parent 22b0ef4 commit 078d410

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

mllib/src/main/scala/org/apache/spark/mllib/fpm/PrefixSpan.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -125,7 +125,7 @@ class PrefixSpan private (
125125
(RDD[(Array[Int], Long)], RDD[(Array[Int], Array[Int])]) = {
126126
val prefixAndFreqentItemAndCounts = prefixAndProjectedDatabase.flatMap{ x =>
127127
x._2.distinct.map(y => ((x._1.toSeq, y), 1L))
128-
}.reduceByKey(_+_)
128+
}.reduceByKey(_ + _)
129129
.filter(_._2 >= minCount)
130130
val patternAndCounts = prefixAndFreqentItemAndCounts
131131
.map(x => (x._1._1.toArray ++ Array(x._1._2), x._2))

0 commit comments

Comments
 (0)