加载本地文件时spark_session和sqlContext之间的区别

我正在粘贴一个可能有用的示例代码。我们用它来创建一个Sparksession对象并用它读取一个本地文件：

import org.apache.spark.sql.SparkSession

object SetTopBox_KPI1_1 {

def main(args: Array[String]): Unit = {

if(args.length < 2) {
  System.err.println("SetTopBox Data Analysis <Input-File> OR <Output-File> is missing")
  System.exit(1)
}

val spark = SparkSession.builder().appName("KPI1_1").getOrCreate()

val record = spark.read.textFile(args(0)).rdd

总的来说，在Spark 2.2中，使用Spark的首选方法是创建一个SparkSession对象。