数据库
首页 > 数据库> > SparkSQL——SQLContext的使用

SparkSQL——SQLContext的使用

作者:互联网

SQLContext的使用

SQLContext在Spark1.6中使用,在spark2.x中已经标记为过时,不推荐使用。

示例代码
package com.spark

import org.apache.spark.{SparkConf, SparkContext}
import org.apache.spark.sql.SQLContext

/*
  SQLContext的使用
 */
object SQLContextAPP {

  def main(args: Array[String]): Unit = {
    val path="E:\\data\\people.json"

    //1)创建相应的Context
    val sparkConf=new SparkConf()
    sparkConf.setAppName("SQLContextApp").setMaster("local[2]")
    val sc= new SparkContext(sparkConf)
    val sqlContext =new SQLContext(sc)

    //2)相关的处理
    val people=sqlContext.read.format("json").load(path)
    people.printSchema()
    people.show()


    //3)关闭资源
    sc.stop()
  }
}

 

标签:val,people,SparkSQL,使用,new,spark,sparkConf,SQLContext
来源: https://www.cnblogs.com/aishanyishi/p/10317908.html