Как выровнять СД для кортежа, если в нем есть компонент Option

Question

Я знаю, если я хочу преобразовать xs: RDD[Option[T]] to List[T], я просто пишу xs.flatten

Теперь, если у меня есть rs:RDD[(Option[T], S)] Как мне преобразовать это в RDD[T, S], если есть какая-либо опция, кромеФильтр вызовов и карта.

Answer 1

Вы можете вызвать карту и использовать сопоставление с образцом:

rs.map {case (Some(t), s) => t->s}