Hi
It worked for me like this. Just define the case class outside of any class
to write to parquet format successfully. I am using Spark version 1.1.1.
case class person(id: Int, name: String, fathername: String, officeid: Int)
object Program {
def main (args: Array[String]) {
val
Hi,
I have created a parquet-file from case-class using saveAsParquetFile
Then try to reload using parquetFile but it fails.
Sample code is attached.
Any help would be appreciated.
Regards,
Rahul
rahul@...
sample_parquet.sample_parquet
