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命令行,执行如下
2023-06-20编程教程下载本文spark,SQL,创建
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.doc》
下载本文的Word格式文档,以方便收藏与打印。