Как загрузить файл конфигурации YAML в Scala, чтобы преобразовать его в CSV вместе с файлом XML, который содержит необработанные данные - PullRequest
0 голосов
/ 13 февраля 2019

У меня есть файл XML, который является необработанным файлом, и у меня есть файл конфигурации YAML с rowtags, и его значения находятся только в файле XML.Я хочу создать CSV-файл в Scala, используя оба вышеуказанных файла.Как я могу сделать это в Scala?

import java.io.{File, FileInputStream}
import org.yaml.snakeyaml.Yaml
import org.yaml.snakeyaml.constructor.Constructor
import java.util.Map;

case class data (employee: String)

var yamlData = 
   spark.sparkContext.wholeTextFiles( "dbfs:/FileStore/tables/forex_sample.yml")
     .map(x => x._2)
     .collect()(0)

val yaml = new Yaml()
var config = 
      yaml.load(yamlData)
        .asInstanceOf[java.util.Map[String, String]]
var item = config.get("employee")
println("item")
print (config)
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...