嗨,社區,
我不知道發生了什麼《旅。
我有一個使用情況數據寫入的位置“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行。
什麼好主意嗎?
