海牛部落 spark 系列教程（四十二）：spark-sql 编程

1.spark-sql的json

pom

代码

结果

save的结果

2.spark-sql自定义schema

数据集，只不过以文本形式表示

把log4j的级别改成warn方便看日志，从集群上拿log4j.properties文件放到

程序结果

3.spark-sql用对象自定义schema

首先定义一个数据bean，作用是可以根据这个数据bean通过反射的方式映射出表的结构和生成ds数据集

代码: 用sql语句代替ds的api

结果：

代码

结果