org.apache.hadoop.mapreduce.lib.jobcontrol

クラス JobControl

java.lang.Object

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

すべての実装されたインタフェース:

Runnable

直系の既知のサブクラス:

JobControl

@InterfaceAudience.Public
 @InterfaceStability.Evolving
public class JobControl
extends Object
implements Runnable

This class encapsulates a set of MapReduce jobs and its dependency. It tracks the states of the jobs by placing them into different tables according to their states. This class provides APIs for the client app to add a job to the group and to get the jobs in the group in different states. When a job is added, an ID unique to the group is assigned to the job. This class has a thread that submits jobs when they become ready, monitors the states of the running jobs, and updates the states of jobs based on the state changes of their depending jobs states. The class provides APIs for suspending/resuming the thread, and for stopping the thread.

コンストラクタのサマリー

コンストラクタ

コンストラクタと説明
JobControl(String groupName) Construct a job control for a group of jobs.

メソッドのサマリー

修飾子とタイプ	メソッドと説明
String	addJob(ControlledJob aJob) Add a new controlled job.
String	addJob(Job aJob) Add a new job.
void	addJobCollection(Collection<ControlledJob> jobs) Add a collection of jobs
boolean	allFinished()
List<ControlledJob>	getFailedJobList()
List<ControlledJob>	getReadyJobsList()
List<ControlledJob>	getRunningJobList()
List<ControlledJob>	getSuccessfulJobList()
org.apache.hadoop.mapreduce.lib.jobcontrol.JobControl.ThreadState	getThreadState()
List<ControlledJob>	getWaitingJobList()
void	resume() resume the suspended thread
void	run() The main loop for the thread.
void	stop() set the thread state to STOPPING so that the thread will stop when it wakes up.
void	suspend() suspend the running thread

クラスから継承されたメソッド java.lang.Object

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

コンストラクタの詳細

JobControl

public JobControl(String groupName)

Construct a job control for a group of jobs.

パラメータ:

groupName - a name identifying this group

メソッドの詳細

getWaitingJobList

public List<ControlledJob> getWaitingJobList()

戻り値:

the jobs in the waiting state

getRunningJobList

public List<ControlledJob> getRunningJobList()

戻り値:

the jobs in the running state

getReadyJobsList

public List<ControlledJob> getReadyJobsList()

戻り値:

the jobs in the ready state

getSuccessfulJobList

public List<ControlledJob> getSuccessfulJobList()

戻り値:

the jobs in the success state

getFailedJobList

public List<ControlledJob> getFailedJobList()

addJob

public String addJob(ControlledJob aJob)

Add a new controlled job.

パラメータ:

aJob - the new controlled job

addJob

public String addJob(Job aJob)

Add a new job.

パラメータ:

aJob - the new job

addJobCollection

public void addJobCollection(Collection<ControlledJob> jobs)

Add a collection of jobs

パラメータ:

jobs -

getThreadState

public org.apache.hadoop.mapreduce.lib.jobcontrol.JobControl.ThreadState getThreadState()

戻り値:

the thread state

stop

public void stop()

set the thread state to STOPPING so that the thread will stop when it wakes up.

suspend

public void suspend()

suspend the running thread

resume

public void resume()

resume the suspended thread

allFinished

public boolean allFinished()

run

public void run()

The main loop for the thread. The loop does the following: Check the states of the running jobs Update the states of waiting jobs Submit the jobs in ready state

定義:

run インタフェース内 Runnable