在没有编译警告的情况下从 RDD[Try[T]] 获取 Failure[T] 的 RDD
Getting an RDD of Failure[T] from an RDD[Try[T]] without compilation warning
我有一个 RDD[Try[T]]，我想 trasnfRDD 只包含类型 Failure[T] 的元素，这意味着方法 isFailure 所针对的所有元素returnstrue。至此，我找到了以下解决方案。
rows.filter(row => row.isFailure)
.map {
case Failure(e) => // Do something...
}
警告：(11, 36) 匹配可能并不详尽。
它会在以下输入时失败：Success(_)
地图 {
有没有什么方法可以在不报编译警告的情况下获得相同的结果？
非常感谢。
乍一看 collect 更适合这里：
rows.collect {
case f @ Failure(e) => f
}
我有一个 RDD[Try[T]]，我想 trasnfRDD 只包含类型 Failure[T] 的元素，这意味着方法 isFailure 所针对的所有元素returnstrue。至此，我找到了以下解决方案。
rows.filter(row => row.isFailure)
.map {
case Failure(e) => // Do something...
}
警告：(11, 36) 匹配可能并不详尽。 它会在以下输入时失败：Success(_) 地图 {
有没有什么方法可以在不报编译警告的情况下获得相同的结果？
非常感谢。
乍一看 collect 更适合这里：
rows.collect {
case f @ Failure(e) => f
}