spark2 sql读取json文件的格式要求续：如何查询数据

问题导读

1.DataFrame如何创建tempview？2.sql()函数的作用是什么？




spark2 sql读取json文件的格式要求
http://www.aboutyun.com/forum.php?mod=viewthread&tid=23478


上面我们将json数据导入了DataFrame，接着我们下面操作：
使用DataFrame创建people表
[mw_shl_code=applescript,true]peopleDF.createOrReplaceTempView("people")
[/mw_shl_code]


创建表后，接着我们就可以使用spark sql查询，比如查询aboutyun的信息
[mw_shl_code=bash,true]val nameDF=spark.sql("select * from people where name='aboutyun'")[/mw_shl_code]



[mw_shl_code=bash,true]nameDF.show[/mw_shl_code]



相关文章：
spark2 sql读取json文件的格式要求
http://www.aboutyun.com/forum.php?mod=viewthread&tid=23478


spark2 sql读取json文件的格式要求续：如何查询数据
http://www.aboutyun.com/forum.php?mod=viewthread&tid=23483

spark2 sql编程之实现合并Parquet格式的DataFrame的schema
http://www.aboutyun.com/forum.php?mod=viewthread&tid=23518

spark2 sql编程样例：sql操作
http://www.aboutyun.com/forum.php?mod=viewthread&tid=23501

spark2 sql读取数据源编程学习样例1：程序入口、功能等知识详解
http://www.aboutyun.com/forum.php?mod=viewthread&tid=23484


spark2 sql读取数据源编程学习样例2：函数实现详解
http://www.aboutyun.com/forum.php?mod=viewthread&tid=23489


spark2 sql编程之实现合并Parquet格式的DataFrame的schema
http://www.aboutyun.com/forum.php?mod=viewthread&tid=23518