We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 793f85c commit 737d8bbCopy full SHA for 737d8bb
mllib/src/main/scala/org/apache/spark/mllib/fpm/FPGrowth.scala
@@ -90,7 +90,8 @@ class FPGrowth private (
90
new FPGrowthModel(freqItemsets)
91
}
92
93
- def run[Item: ClassTag, Basket <: JavaIterable[Item]](data: JavaRDD[Basket]): FPGrowthModel[Item] = {
+ def run[Item: ClassTag, Basket <: JavaIterable[Item]](
94
+ data: JavaRDD[Basket]): FPGrowthModel[Item] = {
95
this.run(data.rdd.map(_.asScala))
96
97
0 commit comments