Как загрузить MultipartFile в Спарк с Scala

Question

Я пытаюсь загрузить CSV-файл, который приходит Форма запроса на пост, получив имя файла, как этот

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

Но это дает путь не найдена ошибка. Мой вопрос заключается в том, как загрузить многочастный файл в искру.

Answer 1

Необходимо передать материальный файл в локальную файловую систему, прежде чем передавать его в Spark.

Итак, сначала сохраните файл POST ed с использованием любой используемой инфраструктуры HTTP, возьмите место в локальной файловой системе и используйте это для вызова Spark.