如何星火加载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。