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(",")) //当有标题的时候
相关文章
相关标签/搜索