Spark DAG 执行流程

文章目录 Action 启动程序执行 DAGScheduler.scala 提交Job 执行 根据Job建立Stage DAG图 Stage执行结束 Task 的调度和执行 Action 启动程序执行 // Dataset.scala // scalastyle:off println def show(numRows: Int, truncate: Boolean): Unit = if

>>阅读原文<<