
JobWaiter
JobWaiter [crayon-6926ae334a1a0009702397/] JobWaiter is a JobListener that is used when DAGScheduler submits a job ...
spark技术分享
JobWaiter [crayon-6926ae334a1a0009702397/] 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
一周热门排行