Package fr.ens.biologie.genomique.eoulsan.util.hadoop

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

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.

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Details

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 id

InterruptedException - if an error occurs while getting the job id

Method Details

stop

public void stop()

Description copied from interface: EmergencyStopTask

Execute the stop task.

Specified by:

stop in interface EmergencyStopTask

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

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 id

InterruptedException - 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 id

InterruptedException - if an error occurs while getting the job id