本地模式使用JAVA SACLA 开发 Spark SQL DataFrame

原文件：

{"name":"Michael"} {"name":"Andy", "age":30} {"name":"Justin", "age":19}

java

 

package com.dt.sparkApps.sql;

import org.apache.spark.SparkConf; import org.apache.spark.api.java.JavaSparkContext; import org.apache.spark.sql.DataFrame; import org.apache.spark.sql.SQLContext;

public class DataFrameOps {

 public static void main(String[] args) {   // TODO Auto-generated method stub      SparkConf conf=new SparkConf().setAppName("DataFrameOps").setMaster("local");      JavaSparkContext sc=new JavaSparkContext(conf);      SQLContext sqlContext=new SQLContext(sc);      //DataFrame df=sqlContext.read().json("hdfs://master:9000/library/people.json");   DataFrame df=sqlContext.read().json("G://IMFBigData