如果它具有 Option 组件，如何展平元组的 RDD

【问题标题】：How to flatten a RDD of tuple if it has an Option component如果它具有 Option 组件，如何展平元组的 RDD
【发布时间】：2020-01-21 01:32:45
【问题描述】：

我知道如果我要转换xs: RDD[Option[T]] to List[T]，我只是写 xs.flatten

现在，如果我有 rs:RDD[(Option[T], S)] 我如何将其转换为 RDD[T, S] 如果除了调用过滤器和映射之外还有其他选项。

【问题讨论】：

【解决方案1】：

你可以调用map并使用模式匹配：

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

【讨论】：