При использовании pyspark, можем ли мы использовать функцию lowerByKey для возврата нескольких выходов для одного и того же ключа? - PullRequest
0 голосов
/ 20 февраля 2020

Я использовал FlatMap и для отображения каждой строки 1, как это (a1, [b1, c1]). Теперь я хочу уменьшить его так, чтобы он возвращал несколько выходных данных, например:

[(a1, b1), c1],
[(a1, b2), c1+c2],
[(a1, b3), c1+c2+c3].....and so on.
...