import pyspark sc = pyspark.SparkContext() sql = SQLContext(sc) df = (sql.read .format("com.databricks.spark.csv") .option("header", "true") .load("FireData-Part2.csv")) df.show()
https://blog.csdn.net/qq_36603091/article/details/79626675