Подход модели исполнения искровой работы - PullRequest
Новая
       11

Подход модели исполнения искровой работы

0 голосов
/ 26 ноября 2018

{"cust": "Розничная торговля", "таблицы": [

{
    "Name":"customer",
    "table_NAME":"cust",
    "param1":"cust_id",  
    "val":"112",
    "op":"cust_name"

},
{
        "Name":"sales",
    "table_NAME":"sale",
    "param1":"country",  
    "val":"ind",
    "op":"monthly_sale"
}
]

}

{"cust": "Retail1", "таблицы": [

{
    "Name":"customer",
    "table_NAME":"cust",
    "param1":"cust_id",  
    "val":"112",
    "op":"cust_name"

}
]

}

как прочитать файл json выше, перейти к таблицам и сформировать динамический SQL-запрос, выполнить его в БД mongo?

нам нужно сформировать несколько запросов из таблиц (т.е.)

выберите имя cust_name из cust, где cust_id = 112

получите результат и сохраните его в файле json (json1).

то же самое, что SELECT MONTHLY_SALE FROM SALE WHERECOUNTRY = 'IND'

, и мы должны сохранить этот результат в указанном выше файле json (json1)

здесь, нам нужно создать 2 файла json, потому что у нас есть 2 объекта (в розницу - json1, retail1 - json2)

Какой наилучший подход для этого (spark-scala)?

...