有这么一个需求:让rdd1执行map(或其他算子),当出现满足条件的情况时,控制整个spark程序停止,或是保存停止结果到文件(优先保存结果到文件),而不继续执行后续步骤
//示例,大概就是这么一个意思:当出现值为5的行,停止程序或是保存结果
val rdd2 = rdd1.map(x =>{
if(x==5){
//整个spark程序停止,或是保存停止结果到文件
}
...........
}
)
rdd2.count()
请问有什么可以实现的方法吗?