Я новичок в Скале. Я пытаюсь записать вывод в файл, используя sparkJob. Сгенерированные файлы имеют образец ниже.
id1, WrappedArray(id2, id3).
Однако я ожидаю, что результат будет следующим.
id1, id2, id3.
У меня есть класс case, который определяет мою dataStructure как
case class MyMap(key1: String, ids: List[String])
фрагмент кода, как показано ниже.
DataSerializationUtils.saveAsTabSepFiles(
"keyswithIds",
myMap.toDF,
outputFolder,
clusterLogger)