Class ClusterJobEmergencyStopTask

  • All Implemented Interfaces:
    EmergencyStopTask

    public class ClusterJobEmergencyStopTask
    extends Object
    implements EmergencyStopTask
    This class define an EmergencyStopTask for cluster Jobs.
    Since:
    2.0
    Author:
    Laurent Jourdren
    • Constructor Detail

      • ClusterJobEmergencyStopTask

        public ClusterJobEmergencyStopTask​(ClusterTaskScheduler scheduler,
                                           String jobId)
        Public constructor.
        Parameters:
        scheduler - the cluster scheduler
        jobId - the job id
    • Method Detail

      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class Object
      • addHadoopJobEmergencyStopTask

        public static void addHadoopJobEmergencyStopTask​(ClusterTaskScheduler scheduler,
                                                         String jobId)
        Add a cluster Job to the EmergencyStopTasks.
        Parameters:
        scheduler - the cluster scheduler
        jobId - the job id
      • removeHadoopJobEmergencyStopTask

        public static void removeHadoopJobEmergencyStopTask​(ClusterTaskScheduler scheduler,
                                                            String jobId)
        Remove a cluster Job to the EmergencyStopTasks.
        Parameters:
        scheduler - the cluster scheduler
        jobId - the job id