【大数据开发】Spark SQL的SparkSession介绍（二）

Part

//Java
import org.apache.spark.sql.SparkSession;


public class SqlExampleJava {
    public static void main(String[] args) {
        SparkSession spark = SparkSession.builder()
                .appName("test")
                .master("local")
                .config("spark.sql.warehouse.dir","/Users/zhangjingyu/Desktop/Spark架构/spark-warehouse")
                .getOrCreate();
    }
}


//Scala
import org.apache.spark.sql.SparkSession


object SqlExampleScala {
  def main(args: Array[String]): Unit = {
    val spark = SparkSession.builder()
      .appName("test")
      .master("local")
      .config("spark.sql.warehouse.dir", "/Users/zhangjingyu/Desktop/Spark架构/spark-warehouse")
      .getOrCreate()
  }


}