spark sql 创建DataFrame

SQLContext是创建DataFrame和执行SQL语句的入口

通过RDD结合case class转换为DataFrame

1、准备:
hdfs上提交一个文件,schema为id name age,内容如下

1 zhansgan 16
2 lisi 18
3 wangwu 21
4 xiaofang 22

2、打开spark-shell命令行,执行如下

原文地址:https://www.cnblogs.com/heml/p/6773321.html