Сценарий:
Я читаю файл конфигурации в формате JSON. Файл имеет 2 атрибута.
{
"env":"dev"
"table_list" :["table1","table2"]
}
Мне нужно прочитать значения из table_list, т. Е. Table1 и table2, и выполнить мой код.
Чтение JSON:
val read_json = spark.read.option("multiline",
"true").json("/mnt/config/sample1.json")
var tables = read_json.select("table_list") , this gives result as
org.apache.spark.sql.DataFrame = [table_list: array<string>]
Как я могу перебрать список таблиц и получить значения table_list.
Мне нужно как-то разделить, используя запятую (,), или есть какой-нибудь другой способ прочитать строку из table_list.
Пробовал несколько кодов:
var t = tables.first
var mapped = t.getAs[WrappedArray[String]](0)
Это дает результат как,
mapped: scala.collection.mutable.WrappedArray[String] = WrappedArray(table1, table2)
Спасибо Сатья