spark sql 创建DataFrame

2023-06-20,,

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命令行,执行如下

spark sql 创建DataFrame的相关教程结束。

《spark sql 创建DataFrame.doc》

下载本文的Word格式文档,以方便收藏与打印。