У меня есть следующий входной кортеж, который я хотел бы использовать для flatMap: (String, List[String])
НАПРИМЕР. Вход:
("a", ["1", "2"])
("b", ["3", "4"])
Необходимый вывод:
("a", "1")
("a", "2")
("b", "3")
("b", "4")
Есть ли элегантный способ сделать это в Scalding/Scala?
Вы можете сделать это с помощью многострочного выражения for ... yield:
for {
(a, bs) <- tupleList
b <- bs
} yield (a, b)
Возможно, это не лучшее решение, но каскадные карты, а затем выравнивание результата были лучшим, что я мог придумать.
Удивительная вещь в FP заключается в том, что вы можете делать одно и то же совершенно по-разному. Надеюсь, кто-нибудь опубликует другое решение
val input = List( ("a", List("1", "2")), ("b", List("3","4")))
val output = input.map(it => it._2.map { (it._1, _)}).flatten
Как указано, вывод может измениться на
input.flatMap(tuple => tuple._2.map { (tuple._1 , _) })
