File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
mllib/src/main/scala/org/apache/spark/mllib/fpm Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -124,7 +124,7 @@ class PrefixSpan private (
124124 val freqItemSets = freqItemCounts.keys.toSet
125125 val freqItems = freqItemSets.flatten
126126 sequences.flatMap { seq =>
127- val filteredSeq = seq.map(item => freqItems.intersect(item)).filterNot (_.isEmpty )
127+ val filteredSeq = seq.map(item => freqItems.intersect(item)).filter (_.nonEmpty )
128128 freqItemSets.flatMap { item =>
129129 val candidateSuffix = LocalPrefixSpan .getSuffix(item, filteredSeq)
130130 candidateSuffix match {
@@ -229,7 +229,7 @@ class PrefixSpan private (
229229 val frequentNextItems = frequentNextItemSets.flatten
230230 val filteredSuffix = suffix
231231 .map(item => frequentNextItems.intersect(item))
232- .filterNot (_.isEmpty )
232+ .filter (_.nonEmpty )
233233 frequentNextItemSets.flatMap { item =>
234234 LocalPrefixSpan .getSuffix(item, filteredSuffix) match {
235235 case suffix if ! suffix.isEmpty => Some (item :: prefix, suffix)
You can’t perform that action at this time.
0 commit comments