JobWaiter
JobWaiter [crayon-6741c76554bb2157272433/] JobWaiter is a JobListener that is used when DAGScheduler submits a job ...
JobWaiter [crayon-6741c76554bb2157272433/] JobWaiter is a JobListener that is used when DAGScheduler submits a job ...
JobListener Spark subscribes for job completion or failure events (after submitting a job to DAGScheduler) using J ...
DAGSchedulerEventProcessLoop — DAGScheduler Event Bus
DAGSchedulerSource — Metrics Source for DAGScheduler
StageInfo Caution FIXME fromStage Method Caution FIXME
ResultStage — Final Stage in Job
ShuffleMapStage — Intermediate Stage in Execution DAG
Stage — Physical Unit Of Execution
ActiveJob A job (aka action job or active job) is a top-level work item (computation) submitted to DAGScheduler to ...
DAGScheduler — Stage-Oriented Scheduler