Re: Iterate over contents of schemaRDD loaded from parquet file to extract timestamp

2015-03-16 Thread Cheng Lian
r, r(2).toString.toInt, r(3).toString) } This gives me * org.apache.spark.SparkException: Task not serializable* Please help !!! -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/Iterate-over-contents-of-schemaRDD-loaded-from-parquet-file-to-extract-timestamp-tp2208

Iterate over contents of schemaRDD loaded from parquet file to extract timestamp

2015-03-16 Thread anu
ndar.get(Calendar.HOUR_OF_DAY); Row(r(0).toString.toInt, r1, hour, r(2).toString.toInt, r(3).toString) } This gives me * org.apache.spark.SparkException: Task not serializable* Please help !!! -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/Iterate-over-contents