如何强制Spark执行map调用,即使它认为由于惰性评估而不需要执行?
我尝试在map调用中使用cache(),但仍然没有成功。我的map方法实际上将结果上传到HDFS。所以,它并不是无用的,但是Spark认为它是无用的。
cache()
用户名或电子邮箱地址
密码