org.apache.hadoop.mapred

Class ChukwaJobTrackerInstrumentation

java.lang.Object

org.apache.hadoop.mapred.ChukwaJobTrackerInstrumentation

public class ChukwaJobTrackerInstrumentation
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.hadoop.mapred.JobTracker	tracker

Constructor Summary

Constructors

Constructor and Description
ChukwaJobTrackerInstrumentation(org.apache.hadoop.mapred.JobTracker jt, org.apache.hadoop.mapred.JobConf conf)

Method Summary

Methods

Modifier and Type	Method and Description
void	addBlackListedMapSlots(int arg0)
void	addBlackListedReduceSlots(int arg0)
void	addBlackListedTrackers(int arg0)
void	addGrayListedTrackers(int arg0)
void	addOccupiedMapSlots(int arg0)
void	addOccupiedReduceSlots(int arg0)
void	addPrepJob(org.apache.hadoop.mapred.JobConf arg0, org.apache.hadoop.mapred.JobID arg1)
void	addReservedMapSlots(int arg0)
void	addReservedReduceSlots(int arg0)
void	addRunningJob(org.apache.hadoop.mapred.JobConf arg0, org.apache.hadoop.mapred.JobID arg1)
void	addRunningMaps(int arg0)
void	addRunningReduces(int arg0)
void	addTrackers(int arg0)
void	addWaitingMaps(org.apache.hadoop.mapred.JobID arg0, int arg1)
void	addWaitingReduces(org.apache.hadoop.mapred.JobID arg0, int arg1)
void	completeJob(org.apache.hadoop.mapred.JobConf arg0, org.apache.hadoop.mapred.JobID arg1)
void	completeMap(org.apache.hadoop.mapred.TaskAttemptID arg0)
void	completeReduce(org.apache.hadoop.mapred.TaskAttemptID arg0)
void	decBlackListedMapSlots(int arg0)
void	decBlackListedReduceSlots(int arg0)
void	decBlackListedTrackers(int arg0)
void	decGrayListedTrackers(int arg0)
void	decOccupiedMapSlots(int arg0)
void	decOccupiedReduceSlots(int arg0)
void	decPrepJob(org.apache.hadoop.mapred.JobConf arg0, org.apache.hadoop.mapred.JobID arg1)
void	decReservedMapSlots(int arg0)
void	decReservedReduceSlots(int arg0)
void	decRunningJob(org.apache.hadoop.mapred.JobConf arg0, org.apache.hadoop.mapred.JobID arg1)
void	decRunningMaps(int arg0)
void	decRunningReduces(int arg0)
void	decTrackers(int arg0)
void	decWaitingMaps(org.apache.hadoop.mapred.JobID arg0, int arg1)
void	decWaitingReduces(org.apache.hadoop.mapred.JobID arg0, int arg1)
void	failedJob(org.apache.hadoop.mapred.JobConf arg0, org.apache.hadoop.mapred.JobID arg1)
void	failedMap(org.apache.hadoop.mapred.TaskAttemptID arg0)
void	failedReduce(org.apache.hadoop.mapred.TaskAttemptID arg0)
void	finalizeJob(org.apache.hadoop.mapred.JobConf conf, org.apache.hadoop.mapred.JobID id)
void	heartbeat()
void	killedJob(org.apache.hadoop.mapred.JobConf arg0, org.apache.hadoop.mapred.JobID arg1)
void	killedMap(org.apache.hadoop.mapred.TaskAttemptID arg0)
void	killedReduce(org.apache.hadoop.mapred.TaskAttemptID arg0)
void	launchMap(org.apache.hadoop.mapred.TaskAttemptID arg0)
void	launchReduce(org.apache.hadoop.mapred.TaskAttemptID arg0)
void	setDecommissionedTrackers(int arg0)
void	setMapSlots(int arg0)
void	setReduceSlots(int arg0)
void	submitJob(org.apache.hadoop.mapred.JobConf conf, org.apache.hadoop.mapred.JobID id)
void	terminateJob(org.apache.hadoop.mapred.JobConf arg0, org.apache.hadoop.mapred.JobID arg1)

Methods inherited from class java.lang.Object

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

Field Detail

tracker

protected final org.apache.hadoop.mapred.JobTracker tracker

Constructor Detail

ChukwaJobTrackerInstrumentation

public ChukwaJobTrackerInstrumentation(org.apache.hadoop.mapred.JobTracker jt,
                               org.apache.hadoop.mapred.JobConf conf)

Method Detail

submitJob

public void submitJob(org.apache.hadoop.mapred.JobConf conf,
             org.apache.hadoop.mapred.JobID id)

finalizeJob

public void finalizeJob(org.apache.hadoop.mapred.JobConf conf,
               org.apache.hadoop.mapred.JobID id)

launchMap

public void launchMap(org.apache.hadoop.mapred.TaskAttemptID arg0)

completeMap

public void completeMap(org.apache.hadoop.mapred.TaskAttemptID arg0)

failedMap

public void failedMap(org.apache.hadoop.mapred.TaskAttemptID arg0)

launchReduce

public void launchReduce(org.apache.hadoop.mapred.TaskAttemptID arg0)

completeReduce

public void completeReduce(org.apache.hadoop.mapred.TaskAttemptID arg0)

failedReduce

public void failedReduce(org.apache.hadoop.mapred.TaskAttemptID arg0)

completeJob

public void completeJob(org.apache.hadoop.mapred.JobConf arg0,
               org.apache.hadoop.mapred.JobID arg1)

terminateJob

public void terminateJob(org.apache.hadoop.mapred.JobConf arg0,
                org.apache.hadoop.mapred.JobID arg1)

addWaitingMaps

public void addWaitingMaps(org.apache.hadoop.mapred.JobID arg0,
                  int arg1)

decWaitingMaps

public void decWaitingMaps(org.apache.hadoop.mapred.JobID arg0,
                  int arg1)

addWaitingReduces

public void addWaitingReduces(org.apache.hadoop.mapred.JobID arg0,
                     int arg1)

decWaitingReduces

public void decWaitingReduces(org.apache.hadoop.mapred.JobID arg0,
                     int arg1)

setMapSlots

public void setMapSlots(int arg0)

setReduceSlots

public void setReduceSlots(int arg0)

addBlackListedMapSlots

public void addBlackListedMapSlots(int arg0)

decBlackListedMapSlots

public void decBlackListedMapSlots(int arg0)

addBlackListedReduceSlots

public void addBlackListedReduceSlots(int arg0)

decBlackListedReduceSlots

public void decBlackListedReduceSlots(int arg0)

addReservedMapSlots

public void addReservedMapSlots(int arg0)

decReservedMapSlots

public void decReservedMapSlots(int arg0)

addReservedReduceSlots

public void addReservedReduceSlots(int arg0)

decReservedReduceSlots

public void decReservedReduceSlots(int arg0)

addOccupiedMapSlots

public void addOccupiedMapSlots(int arg0)

decOccupiedMapSlots

public void decOccupiedMapSlots(int arg0)

addOccupiedReduceSlots

public void addOccupiedReduceSlots(int arg0)

decOccupiedReduceSlots

public void decOccupiedReduceSlots(int arg0)

failedJob

public void failedJob(org.apache.hadoop.mapred.JobConf arg0,
             org.apache.hadoop.mapred.JobID arg1)

killedJob

public void killedJob(org.apache.hadoop.mapred.JobConf arg0,
             org.apache.hadoop.mapred.JobID arg1)

addPrepJob

public void addPrepJob(org.apache.hadoop.mapred.JobConf arg0,
              org.apache.hadoop.mapred.JobID arg1)

decPrepJob

public void decPrepJob(org.apache.hadoop.mapred.JobConf arg0,
              org.apache.hadoop.mapred.JobID arg1)

addRunningJob

public void addRunningJob(org.apache.hadoop.mapred.JobConf arg0,
                 org.apache.hadoop.mapred.JobID arg1)

decRunningJob

public void decRunningJob(org.apache.hadoop.mapred.JobConf arg0,
                 org.apache.hadoop.mapred.JobID arg1)

addRunningMaps

public void addRunningMaps(int arg0)

decRunningMaps

public void decRunningMaps(int arg0)

addRunningReduces

public void addRunningReduces(int arg0)

decRunningReduces

public void decRunningReduces(int arg0)

killedMap

public void killedMap(org.apache.hadoop.mapred.TaskAttemptID arg0)

killedReduce

public void killedReduce(org.apache.hadoop.mapred.TaskAttemptID arg0)

addTrackers

public void addTrackers(int arg0)

decTrackers

public void decTrackers(int arg0)

addBlackListedTrackers

public void addBlackListedTrackers(int arg0)

decBlackListedTrackers

public void decBlackListedTrackers(int arg0)

addGrayListedTrackers

public void addGrayListedTrackers(int arg0)

decGrayListedTrackers

public void decGrayListedTrackers(int arg0)

setDecommissionedTrackers

public void setDecommissionedTrackers(int arg0)

heartbeat

public void heartbeat()