Как конвертировать искры SchemaRDD в RDD моего класса case?
В документах spark ясно, как создавать паркетные файлы изRDD ваших собственных тематических классов; (из документов)
val people: RDD[Person] = ??? // An RDD of case class objects, from the previous example.
// The RDD is implicitly converted to a SchemaRDD by createSchemaRDD, allowing it to be stored using Parquet.
people.saveAsParquetFile("people.parquet")
Но не ясно, как конвертировать обратно, действительно мы хотим методreadParquetFile где мы можем сделать:
val people: RDD[Person] = sc.readParquestFile[Person](path)
где определены те значения класса case, которые считываются методом.