本人新手,第一次接触spark。
希望大哥们可以提供下代码让我学习一下。非常感谢。
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()