0

来自火花文件

load(): DataFrame
load(path: String): DataFrame
load(paths: String*): DataFrame

我定义了读取 xml 记录的函数

 def ExtractData(RecID: String,table:String)={
    val spark = SparkSession.
      builder.master("local[*]")
     .appName("Insight Application Big Data")
     .getOrCreate()

    val df = spark.read
      .format("com.databricks.spark.xml")
      .option("rowTag", "row")
      .load("src/main/resources/in/FBNK_CATEG_ENTRY.xml")//pass the xml record here
  }

如果我想将 xml 格式的记录传递给.load函数,而不是从文件中加载,我该怎么办,比如.load(inputStreamXML)

4

0 回答 0