Spark2.0如下讀取csv數據並轉化爲RDD

當Spark 版本低於2.0.0時，以及不借助與其餘包的狀況下，能夠用以下方法將csv數據轉化成RDDweb sc = SparkContext() //獲取RDD csvfile = sc.textFile("xxx.csv") //逗號分隔 all = csvfile.map(lambda line: line.split(",")) //當有標題的時候

>>阅读原文<<