diff --git a/mllib/src/main/scala/org/apache/spark/mllib/fpm/FPGrowth.scala b/mllib/src/main/scala/org/apache/spark/mllib/fpm/FPGrowth.scala index 96baac07cb5d4..70955bffa206b 100644 --- a/mllib/src/main/scala/org/apache/spark/mllib/fpm/FPGrowth.scala +++ b/mllib/src/main/scala/org/apache/spark/mllib/fpm/FPGrowth.scala @@ -90,7 +90,8 @@ class FPGrowth private ( new FPGrowthModel(freqItemsets) } - def run[Item: ClassTag, Basket <: JavaIterable[Item]](data: JavaRDD[Basket]): FPGrowthModel[Item] = { + def run[Item: ClassTag, Basket <: JavaIterable[Item]]( + data: JavaRDD[Basket]): FPGrowthModel[Item] = { this.run(data.rdd.map(_.asScala)) }