spark源码阅读一-spark读写文件代码分析

1.读取文件 从本地文件读取sparkcontext.textFile(“abc.txt”) 从hdfs文件读取sparkcontext.textFile("hdfs://s1:8020/user/hdfs/input”) def textFile(     path: String,     minPartitions: Int = defaultMinPartitions): RDD[Stri
相关文章
相关标签/搜索