相关疑难解决方法(0)

如何处理spark map()函数中的Exception?

我想在map()函数中忽略Exception,例如:

rdd.map(_.toInt)
Run Code Online (Sandbox Code Playgroud)

其中rdd是一个RDD[String].

但如果它遇到非数字字符串,它将失败.

什么是忽略任何异常并忽略该行的简单方法?(我不想使用过滤器来处理异常,因为可能有很多其他异常......)

scala apache-spark

6
推荐指数
2
解决办法
1万
查看次数

标签 统计

apache-spark ×1

scala ×1