spark 读取csv 到dataframe

val df = spark.read.format("csv").option("header", "true").load("/usr/local/Cellar/spark-2.3.0/examples/src/main/resources/people.csv")
df.show

《spark 编程方式指定dataframe的 Schema》 如果csv没有第一行,就只能指定schema了,参考这篇文章
http://www.waitingfy.com/archives/4342

4342

Leave a Reply

Name and Email Address are required fields.
Your email will not be published or shared with third parties.