spark文件读写

1 普通textFile读写java 读取hdfs上的文本文件apache scala>val rdd1=sc.textFile("hdfs://hadoop1:9000/myone/input/a.txt")json 进行相关处理,按照文件中每行进行处理ide scala> val rdd2=rdd1.flatMap(line=>line.split("\\s+")).map(d=>(d,1)o
相关文章
相关标签/搜索