我有一对 RDD,格式为:RDD[(String, String)] 和文件中的键列表。我想要一个 RDD,它只包含那些与列表中的键匹配的键值对。我怎样才能做到这一点(最好是在 Scala 中)? 谢谢。
请您参考如下方法:
我想你可能会使用 RDD.filter:
rdd.filter(yourKeysList.contains(_._1))
Here是一些使用 Scala 或 Python 进行过滤的更具描述性的示例。
我有一对 RDD,格式为:RDD[(String, String)] 和文件中的键列表。我想要一个 RDD,它只包含那些与列表中的键匹配的键值对。我怎样才能做到这一点(最好是在 Scala 中)? 谢谢。
请您参考如下方法:
我想你可能会使用 RDD.filter:
rdd.filter(yourKeysList.contains(_._1))
Here是一些使用 Scala 或 Python 进行过滤的更具描述性的示例。