取消
顯示的結果
而不是尋找
你的意思是:

讀取數據從“dbfs: / mnt /”

帕特
尊敬的貢獻者三世

嗨,社區,

我不知道發生了什麼《旅。

我有一個使用情況數據寫入的位置“dbfs: / mnt /……”,不要問我為什麼,這隻是一個小項目。我相信在ADLS2數據存儲。

我一直試圖讀取數據後寫的但是當我試著從文件夾中讀取數據:

df = spark.read.format(“鋪”).load (“dbfs: / mnt /表/”)或df = spark.read.format .load(“鋪”)(“dbfs: / mnt /表/日期= 2022-12-16 ")

我:AnalysisException:無法推斷模式拚花。它必須手動指定。

當我提供模式,count = 0(零):

df.count ()

但是當我拚花提供完整路徑文件工作原理:

df = spark.read.format(“鋪”).load (“dbfs: / mnt /表/日期= 2022-12-16 / some-spark-file.snappy.parquet”) df.count ()

它返回700行。

什麼好主意嗎?:slightly_smiling_face:

5回複5

Aviral-Bhardwaj
尊敬的貢獻者三世

謝謝你的分享,我希望它會奏效

歡迎來到磚社區:讓學習、網絡和一起慶祝

加入我們的快速增長的數據專業人員和專家的80 k +社區成員,準備發現,幫助和合作而做出有意義的聯係。

點擊在這裏注冊今天,加入!

參與令人興奮的技術討論,加入一個組與你的同事和滿足我們的成員。

Baidu
map