scala import org.apache.spark.sql.SparkSession object SparkExample { def main(args: Array[String]): Unit = { val spark = SparkSession.builder() .appName("Spark Example") .master("local") .getOrCreate() val data = spark.read .format("csv") .option("header", "true") .load("data.csv") data.show(10) spark.stop() } }


上一篇:
下一篇:
切换中文