Как преобразовать RDD like ((int, int), int) в 3 пары ключ-значение в одной функции карты в искрах?

Question

Прямо сейчас у меня есть RDD в следующем формате

((int, int), int) 

, и я стараюсь, чтобы преобразовать его в 3-х пар ключ-значение, как (Int, 1).

я могу сделать это с помощью 3 карты функции затем соединить их вместе, но это определенно не лучший способ ее реализации,

также используя случай я могу создать список ((междунар, 1), (int, 1), (int, 1)), но как я могу сгенерировать List of (int, 1)?

Answer 1

Может быть, вы хотите flatMap?

rdd.flatMap { case ((x, y), z) => List((x, 1), (y, 1), (z, 1)) } 

Приведенные выше код производит RDD[(Int, Int)], расширяет каждый из вложенных кортежей в вашем РДУ на три отдельные элементы RDD.

Answer 2

Это не должно занять три функции карты, но одну функцию карты, как показано ниже

inputRDD.map({case ((x,y),z) => ((x,1),(y,1),(z,1))})