спарк прочитать запись базы данных XML как XML inputStream вместо загрузки из пути к файлу - PullRequest
Новая
       40

спарк прочитать запись базы данных XML как XML inputStream вместо загрузки из пути к файлу

0 голосов
/ 25 декабря 2018

Из искрового документа 

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 в *Функция 1007 * вместо загрузки из файла, что-то вроде .load(inputStreamXML)

...