Работаю с PySpark, есть массив данных, который я пихаю в

Question

Работаю с PySpark, есть массив данных, который я пихаю в

sparkContext.parallelize(args), которые я хочу замапить в функции, чтобы она соотвественно стала джобой, но помимо этих данных, которые я распараллелил, я хочу к каждому партишону добавить дополнительные одни и те же данные, с которыми работает func в которую я маплю все. Как это лучше сделать?

#backend #programming #python #russian

0

21.07.2021