org.apache.giraph.job

Class DefaultJobObserver

java.lang.Object

org.apache.giraph.job.DefaultJobObserver

All Implemented Interfaces:

GiraphConfigurationSettable, ImmutableClassesGiraphConfigurable, GiraphJobObserver

public class DefaultJobObserver
extends Object
implements GiraphJobObserver, ImmutableClassesGiraphConfigurable

Default implementation of job observer that does nothing.

Constructor Summary

Constructors

Constructor and Description
DefaultJobObserver()

Method Summary

Modifier and Type	Method and Description
ImmutableClassesGiraphConfiguration	getConf() Return the configuration used by this object.
void	jobFinished(org.apache.hadoop.mapreduce.Job jobToSubmit, 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.
void	setConf(ImmutableClassesGiraphConfiguration configuration) Set the configuration to be used by this object.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultJobObserver

public DefaultJobObserver()

Method Detail

setConf

public void setConf(ImmutableClassesGiraphConfiguration configuration)

Description copied from interface: GiraphConfigurationSettable

Set the configuration to be used by this object.

Specified by:

setConf in interface GiraphConfigurationSettable

Parameters:

configuration - Set configuration

getConf

public ImmutableClassesGiraphConfiguration getConf()

Description copied from interface: ImmutableClassesGiraphConfigurable

Return the configuration used by this object.

Specified by:

getConf in interface ImmutableClassesGiraphConfigurable

Returns:

Set configuration

launchingJob

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

Description copied from interface: GiraphJobObserver

Callback for job about to start.

Specified by:

launchingJob in interface GiraphJobObserver

Parameters:

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

jobRunning

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

Description copied from interface: GiraphJobObserver

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

Specified by:

jobRunning in interface GiraphJobObserver

Parameters:

submittedJob - Job which was submitted.

jobFinished

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

Description copied from interface: GiraphJobObserver

Callback when job finishes.

Specified by:

jobFinished in interface GiraphJobObserver

Parameters:

jobToSubmit - Job that ran in hadoop.

passed - true if job succeeded.

jobGotAllMappers

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

Description copied from interface: GiraphJobObserver

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

Specified by:

jobGotAllMappers in interface GiraphJobObserver

Parameters:

job - job that runs