Skip to content

Commit de5eeab

Browse files
committed
use API instead of implicits
1 parent 596aba6 commit de5eeab

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

examples/src/main/scala/org/apache/spark/examples/mllib/LDAExample.scala

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -26,8 +26,7 @@ import org.apache.spark.ml.Pipeline
2626
import org.apache.spark.ml.feature.{CountVectorizer, CountVectorizerModel, RegexTokenizer, StopWordsRemover}
2727
import org.apache.spark.ml.linalg.{Vector => MLVector}
2828
import org.apache.spark.mllib.clustering.{DistributedLDAModel, EMLDAOptimizer, LDA, OnlineLDAOptimizer}
29-
import org.apache.spark.mllib.linalg.Vector
30-
import org.apache.spark.mllib.linalg.VectorImplicits
29+
import org.apache.spark.mllib.linalg.{Vector, Vectors}
3130
import org.apache.spark.rdd.RDD
3231
import org.apache.spark.sql.{Row, SparkSession}
3332

@@ -227,7 +226,7 @@ object LDAExample {
227226
val documents = model.transform(df)
228227
.select("features")
229228
.rdd
230-
.map { case Row(features: MLVector) => VectorImplicits.mlVectorToMLlibVector(features) }
229+
.map { case Row(features: MLVector) => Vectors.fromML(features) }
231230
.zipWithIndex()
232231
.map(_.swap)
233232

0 commit comments

Comments
 (0)