Xiangrui Meng created SPARK-5996:
------------------------------------
Summary: DataFrame.collect() doesn't recognize UDTs
Key: SPARK-5996
URL: https://issues.apache.org/jira/browse/SPARK-5996
Project: Spark
Issue Type: Bug
Components: MLlib, SQL
Affects Versions: 1.3.0
Reporter: Xiangrui Meng
Assignee: Michael Armbrust
Priority: Blocker
{code}
import org.apache.spark.mllib.linalg._
case class Test(data: Vector)
val df = sqlContext.createDataFrame(Seq(Test(Vectors.dense(1.0, 2.0))))
df.collect()[0].getAs[Vector](0)
{code}
throws an exception. `collect()` returns `Row` instead of `Vector`.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
