org.apache.hadoop.mapred.jobcontrol

Class JobControl

java.lang.Object

org.apache.hadoop.mapreduce.lib.jobcontrol.JobControl

org.apache.hadoop.mapred.jobcontrol.JobControl

All Implemented Interfaces:

Runnable

@InterfaceAudience.Public
 @InterfaceStability.Stable
public class JobControl
extends JobControl

Constructor Summary

Constructors

Constructor and Description
JobControl(String groupName) Construct a job control for a group of jobs.

Method Summary

Modifier and Type	Method and Description
void	addJobs(Collection<Job> jobs) Add a collection of jobs
ArrayList<Job>	getFailedJobs()
ArrayList<Job>	getReadyJobs()
ArrayList<Job>	getRunningJobs()
int	getState()
ArrayList<Job>	getSuccessfulJobs()
ArrayList<Job>	getWaitingJobs()

Methods inherited from class org.apache.hadoop.mapreduce.lib.jobcontrol.JobControl

addJob, addJob, addJobCollection, allFinished, getFailedJobList, getReadyJobsList, getRunningJobList, getSuccessfulJobList, getThreadState, getWaitingJobList, resume, run, stop, suspend

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JobControl

public JobControl(String groupName)

Construct a job control for a group of jobs.

Parameters:

groupName - a name identifying this group

Method Detail

getWaitingJobs

public ArrayList<Job> getWaitingJobs()

Returns:

the jobs in the waiting state

getRunningJobs

public ArrayList<Job> getRunningJobs()

Returns:

the jobs in the running state

getReadyJobs

public ArrayList<Job> getReadyJobs()

Returns:

the jobs in the ready state

getSuccessfulJobs

public ArrayList<Job> getSuccessfulJobs()

Returns:

the jobs in the success state

getFailedJobs

public ArrayList<Job> getFailedJobs()

addJobs

public void addJobs(Collection<Job> jobs)

Add a collection of jobs

Parameters:

jobs -

getState

public int getState()

Returns:

the thread state