Package org.apache.spark.scheduler

Interface JobListener

public interface JobListener
Interface used to listen for job completion or failure events after submitting a job to the DAGScheduler. The listener is notified each time a task succeeds, as well as if the whole job fails (and no further taskSucceeded events will happen).

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    jobFailed(Exception exception)
     
    void
    taskSucceeded(int index, Object result)
     

  • Method Details

    • jobFailed

      void jobFailed(Exception exception)

    • taskSucceeded

      void taskSucceeded(int index, Object result)