IMF SparkSQLwithJoin 测试sparksql,为114课程测试
http://blog.csdn.net/duan_zhihua/article/details/51590390
people1.json
{"name":"Michael", "score":90}
{"name":"Andy", "score":80}
{"name":"Justin", "score":99}
{"name":"zhangsan", "score":100}
{"name":"zhangsan", "score":96}
SparkSQLwithJoin.java
public class SparkSQLwithJoin {
public static void main(String[] args) {
SparkConf conf = new SparkConf().setMaster("local").setAppName("SparkSQLwithJoin");
JavaSparkContext sc = new JavaSparkContext(conf);
//SQLContext sqlContext = new SQLContext(sc);
HiveContext sqlContext = new HiveContext(sc);
//针对json文件数据源来创建DataFrame
//DataFrame peoplesDF = sqlContext.read().json("G://IMFBigDataSpark2016//te