用法示例
從路徑中讀取文字檔案:
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)