如何星火加載MultipartFile使用Scala

Question

我試圖加載的是通過獲取文件的名稱這樣

val df= SparkConfig.sc.read.format("csv") 
.schema(TableSchema.getDFSchema()).option("header", "false") 
.csv(file.getOriginalFilename) 

未來形式POST請求一個CSV文件，但它給未發現的錯誤路徑。我的問題是如何加載spark中的多部分文件。

Answer 1

在將文件傳遞給Spark之前，您需要在本地文件系統中實現文件。

因此，首先使用您使用的任何HTTP框架保存POST ed文件，然後抓取本地文件系統中的位置並使用它來調用Spark。