首页 > 解决方案 > 如何在 scala 中加载 YAML 配置文件以将其转换为 CSV 以及具有原始数据的 XML 文件

问题描述

我有一个原始文件的 XML 文件,我有一个 YAML 配置文件,rowtags它的值仅在 XML 文件中。我想通过使用上述两个文件在 Scala 中生成一个 CSV 文件。我怎么能在 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)

标签: xmlscalaapache-sparkyaml

解决方案


推荐阅读