I sh для выполнения некоторых запросов в spark и записи результатов в различные поля документа mongodb.
Например:
Select * from table where field1='a'
до {"query1":{result1}}
, а затем
Select * from table1 where field2='a'
до {{"query1":{result1},"query2":{result2}}
и т. Д. *
Результатами запросов может быть целое число или список топ-10 рейтинга рейтинга агрегации