Hi,

How can I convert an RDD loaded from a Parquet file into its original type:

case class Person(name: String, age: Int)

val rdd: RDD[Person] = ...
rdd.saveAsParquetFile("people")

val rdd2: sqlContext.parquetFile("people")

How can I map rdd2 back into an RDD[Person]?  All of the examples just show
how to use the RDD loaded from Parquet using SQL.

Reply via email to