spark读取parquet文件

spark2.10.6
用newHadoopFile来读取parquet文件
val rdd = sc.newHadoopFile(path,classOf[ParquetInputFormat[String]],classOf[Void],classOf[String])
这个rdd在action操作时会报错，错误的意思就是缺少read support这个类。
请问，我要重写一个类来继承ReadSupport这个类要怎么写，谢谢大神。

nextuser · 发表于 2017-6-27 19:22:06

下面是个例子，楼主模仿即可
[mw_shl_code=scala,true]/**
* 重写：可以重写成员变量和成员方法（重写字段或者方法）
* 子类继承父类
*/
class OverrideOperation{

}

class Person1(val name : String,var age : Int) {
  println("The primarry constructor of Person")
  val school = "BJU"

  def sleep = "8 hours"

  override def toString = "I am a person !"

}
/**
* woker 继承自person ，name，age，salary是woker的成员变量
* 子类必须把父类的主构造器中的参数都填充满（和java不同：继承时采用 super使用父类的成员）
*/
class Worker(name : String ,age : Int ,val salary :Long )extends Person1(name,age){

  println("This is the subClass of person,primary constructor of woker")

  override val school = "Spark" // 复写字段或者是方法都要进行添加重写

  override def toString = "I am a worker !" + super.sleep
}

object Person {
  def main(args: Array[String]): Unit = {
// 构建时先构建父类
val w  = new Worker("spark",5,100000)

println("School :" +w.school )
println(w.toString())
  }
}[/mw_shl_code]