spark version 1.6.0,scala version 2.10.4。
val sqlContext = new SQLContext(sc)本次講解以官網下載的spark-2.1.0里的spark-2.1.0/examples/src/main/resources/people.json為例講解。people.json具體數據及格式如下圖所示:
4.通過read讀入文件
val df = new SQLContext(sc).read.json("E://spark-2.1.0//spark-2.1.0//examples//src//main//resources//people.json")5.通過show()查看結果df.show()5.完整代碼及結果
新聞熱點
疑難解答