Skip to content

Commit 48ca15e

Browse files
committed
used vector type tag for udf call in VectorIndexer
1 parent 0ebd0da commit 48ca15e

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

mllib/src/main/scala/org/apache/spark/ml/feature/VectorIndexer.scala

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -339,9 +339,7 @@ class VectorIndexerModel private[ml] (
339339
override def transform(dataset: DataFrame): DataFrame = {
340340
transformSchema(dataset.schema, logging = true)
341341
val newField = prepOutputField(dataset.schema)
342-
val transformUDF = udf { (vector: Any) =>
343-
transformFunc(vector.asInstanceOf[Vector])
344-
}
342+
val transformUDF = udf { (vector: Vector) => transformFunc(vector) }
345343
val newCol = transformUDF(dataset($(inputCol)))
346344
dataset.withColumn($(outputCol), newCol.as($(outputCol), newField.metadata))
347345
}

0 commit comments

Comments
 (0)