1 何时执行runJob方法
SparkContext提供了runJob方法提交作业,比如foreach(println)这种action操作,触发job的提交,SparkContext#runJob来提交的,当然最终是通过DAGScheduler组件来实现job的提交
2 runJob方法流程图
runJob方法流程如下图所示
1 何时执行runJob方法
SparkContext提供了runJob方法提交作业,比如foreach(println)这种action操作,触发job的提交,SparkContext#runJob来提交的,当然最终是通过DAGScheduler组件来实现job的提交
2 runJob方法流程图
runJob方法流程如下图所示