如何强制Spark执行代码?

11 浏览
0 Comments

如何强制Spark执行代码?

如何强制Spark执行map调用,即使它认为由于惰性评估而不需要执行?

我尝试在map调用中使用cache(),但仍然没有成功。我的map方法实际上将结果上传到HDFS。所以,它并不是无用的,但是Spark认为它是无用的。

0