Hi,
I was trying to programmatically specify a schema and apply it to a RDD of
Rows and save the resulting DataFrame as a parquet file.
Here's what I did:
1. Created an RDD of Rows from RDD[Array[String]]:
val gameId= Long.valueOf(line(0))
val accountType = Long.valueOf(line(1))
val
Hi,
I was trying to programmatically specify a schema and apply it to a RDD of
Rows and save the resulting DataFrame as a parquet file, but I got
java.lang.ClassCastException:
java.lang.String cannot be cast to java.lang.Long on the last step.
Here's what I did:
1. Created an RDD of Rows from
