У меня есть парный RDD типа (String, Array [Double]). Я хочу уменьшить его по ключу при добавлении массива значений в соответствующие индексы
Например ((1, [1,2,3]), (1, [2,3,4])) Вывод должно быть (1, [3,5,7])
Ответ: Определяем пользовательскую функцию и передаем ее в функцию уменьшения.
Любой другой способ сделать это