Class HadoopJobEmergencyStopTask
- java.lang.Object
-
- fr.ens.biologie.genomique.eoulsan.util.hadoop.HadoopJobEmergencyStopTask
-
- All Implemented Interfaces:
EmergencyStopTask
public class HadoopJobEmergencyStopTask extends Object implements EmergencyStopTask
This class define an EmergencyStopTask for Hadoop Jobs.- Since:
- 2.0
- Author:
- Laurent Jourdren
-
-
Constructor Summary
Constructors Constructor Description HadoopJobEmergencyStopTask(org.apache.hadoop.mapreduce.Job job)
Public constructor.
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static void
addHadoopJobEmergencyStopTask(org.apache.hadoop.mapreduce.Job job)
Add an Hadoop Job to the EmergencyStopTasks.boolean
equals(Object obj)
int
hashCode()
static void
removeHadoopJobEmergencyStopTask(org.apache.hadoop.mapreduce.Job job)
Remove an Hadoop Job to the EmergencyStopTasks.void
stop()
Execute the stop task.
-
-
-
Constructor Detail
-
HadoopJobEmergencyStopTask
public HadoopJobEmergencyStopTask(org.apache.hadoop.mapreduce.Job job) throws IOException, InterruptedException
Public constructor.- Parameters:
job
- the Hadoop job- Throws:
IOException
- if an error occurs while getting the job idInterruptedException
- if an error occurs while getting the job id
-
-
Method Detail
-
stop
public void stop()
Description copied from interface:EmergencyStopTask
Execute the stop task.- Specified by:
stop
in interfaceEmergencyStopTask
-
addHadoopJobEmergencyStopTask
public static void addHadoopJobEmergencyStopTask(org.apache.hadoop.mapreduce.Job job) throws IOException, InterruptedException
Add an Hadoop Job to the EmergencyStopTasks.- Parameters:
job
- the Hadoop job- Throws:
IOException
- if an error occurs while getting the job idInterruptedException
- if an error occurs while getting the job id
-
removeHadoopJobEmergencyStopTask
public static void removeHadoopJobEmergencyStopTask(org.apache.hadoop.mapreduce.Job job) throws IOException, InterruptedException
Remove an Hadoop Job to the EmergencyStopTasks.- Parameters:
job
- the Hadoop job- Throws:
IOException
- if an error occurs while getting the job idInterruptedException
- if an error occurs while getting the job id
-
-