1.spark-sql的json
pom
代码
结果
save的结果
2.spark-sql自定义schema
数据集，只不过以文本形式表示
把log4j的级别改成warn方便看日志，从集群上拿log4j.properties文件放到
程序结果
3.spark-sql用对象自定义schema
首先定义一个数据bean，作用是可以根据这个数据bean通过反射的方式映射出表的结构和生成ds数据集
代码: 用sql语句代替ds的api
结果：
代码
结果
回复帖子，然后刷新页面即可查看隐藏内容
版权声明:原创作品,允许转载，转载时务必以超链接的形式表明出处和作者信息。否则将追究法律责任。来自海汼部落－青牛,http://hainiubl.com/topics/195
