org.apache.pig.backend.hadoop

Class PigJobControl

java.lang.Object

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

org.apache.hadoop.mapred.jobcontrol.JobControl

org.apache.pig.backend.hadoop.PigJobControl

All Implemented Interfaces:

Runnable

public class PigJobControl
extends org.apache.hadoop.mapred.jobcontrol.JobControl

extends the hadoop JobControl to remove the hardcoded sleep(5000) as most of this is private we have to use reflection See https://svn.apache.org/repos/asf/hadoop/common/branches/branch-0.23.1/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/jobcontrol/JobControl.java

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.lib.jobcontrol.JobControl

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

Field Summary

Fields

Modifier and Type	Field and Description
protected int	timeToSleep

Constructor Summary

Constructors

Constructor and Description
PigJobControl(String groupName, int timeToSleep) Construct a job control for a group of jobs.

Method Summary

Modifier and Type	Method and Description
int	getTimeToSleep()
void	run() The main loop for the thread.
void	setTimeToSleep(int timeToSleep)

Methods inherited from class org.apache.hadoop.mapred.jobcontrol.JobControl

addJobs, getFailedJobs, getReadyJobs, getRunningJobs, getState, getSuccessfulJobs, getWaitingJobs

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

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

Methods inherited from class java.lang.Object

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

Field Detail

timeToSleep

protected int timeToSleep

Constructor Detail

PigJobControl

public PigJobControl(String groupName,
                     int timeToSleep)

Construct a job control for a group of jobs.

Parameters:

groupName - a name identifying this group

pigContext -

conf -

Method Detail

getTimeToSleep

public int getTimeToSleep()

setTimeToSleep

public void setTimeToSleep(int timeToSleep)

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

Specified by:

run in interface Runnable

Overrides:

run in class org.apache.hadoop.mapreduce.lib.jobcontrol.JobControl