Spark結(jié)構(gòu)化API數(shù)據(jù)源——文本文件

一、讀文本文件
讀文本文件非常簡單:只需要指定類型為textFile即可。如果使用textFile,分區(qū)目錄名將被忽略。如果要根據(jù)分區(qū)讀取和寫入文本文件,你應(yīng)該使用text,它會(huì)在讀寫時(shí)考慮分區(qū)

    spark.read.textFile("/data/flight-data/csv/2010-summary.csv")
      .selectExpr("split(value, ',') as rows").show()

二、寫文本文件

  • 當(dāng)寫文本文件時(shí),需確保僅有一個(gè)字符串類型的列寫出,否則寫操作將失敗
csvFile.select("DEST_COUNTRY_NAME").write.text("tmp/simple-text-file.txt")
  • 如果在執(zhí)行寫操作同時(shí)執(zhí)行某些數(shù)據(jù)分片操作,則可以寫入更多列
csvFile.limit(10).select("DEST_COUNTRY_NAME", "count")
.write.partitionBy("count").text("/tmp/five-csv-files2.csv")
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡書系信息發(fā)布平臺(tái),僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容