org.apache.giraph.job

Interface GiraphJobObserver

All Known Implementing Classes:

DefaultJobObserver

public interface GiraphJobObserver

An observer over the job launch lifecycle.

Method Summary

Modifier and Type	Method and Description
void	jobFinished(org.apache.hadoop.mapreduce.Job submittedJob, boolean passed) Callback when job finishes.
void	jobGotAllMappers(org.apache.hadoop.mapreduce.Job job) Called when job gets all mappers and really starts computations.
void	jobRunning(org.apache.hadoop.mapreduce.Job submittedJob) Callback after job was submitted.
void	launchingJob(org.apache.hadoop.mapreduce.Job jobToSubmit) Callback for job about to start.

Method Detail

launchingJob

void launchingJob(org.apache.hadoop.mapreduce.Job jobToSubmit)

Callback for job about to start.

Parameters:

jobToSubmit - Job we're going to submit to hadoop.

jobRunning

void jobRunning(org.apache.hadoop.mapreduce.Job submittedJob)

Callback after job was submitted. For example, you can track its progress here.

Parameters:

submittedJob - Job which was submitted.

jobFinished

void jobFinished(org.apache.hadoop.mapreduce.Job submittedJob,
                 boolean passed)

Callback when job finishes.

Parameters:

submittedJob - Job that ran in hadoop.

passed - true if job succeeded.

jobGotAllMappers

void jobGotAllMappers(org.apache.hadoop.mapreduce.Job job)

Called when job gets all mappers and really starts computations. May not get called if the job progress tracker fails.

Parameters:

job - job that runs