用法示例
从路径中读取文本文件:
val sc: org.apache.spark.SparkContext = ???
sc.textFile(path="/path/to/input/file")
使用通配符读取文件:
sc.textFile(path="/path/to/*/*")
读取指定最小分区数的文件:
sc.textFile(path="/path/to/input/file", minPartitions=3)
从路径中读取文本文件:
val sc: org.apache.spark.SparkContext = ???
sc.textFile(path="/path/to/input/file")
使用通配符读取文件:
sc.textFile(path="/path/to/*/*")
读取指定最小分区数的文件:
sc.textFile(path="/path/to/input/file", minPartitions=3)