public class DefaultJobObserver extends Object implements GiraphJobObserver, ImmutableClassesGiraphConfigurable
Constructor and Description |
---|
DefaultJobObserver() |
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.
|
public void setConf(ImmutableClassesGiraphConfiguration configuration)
GiraphConfigurationSettable
setConf
in interface GiraphConfigurationSettable
configuration
- Set configurationpublic ImmutableClassesGiraphConfiguration getConf()
ImmutableClassesGiraphConfigurable
getConf
in interface ImmutableClassesGiraphConfigurable
public void launchingJob(org.apache.hadoop.mapreduce.Job jobToSubmit)
GiraphJobObserver
launchingJob
in interface GiraphJobObserver
jobToSubmit
- Job we're going to submit to hadoop.public void jobRunning(org.apache.hadoop.mapreduce.Job submittedJob)
GiraphJobObserver
jobRunning
in interface GiraphJobObserver
submittedJob
- Job which was submitted.public void jobFinished(org.apache.hadoop.mapreduce.Job jobToSubmit, boolean passed)
GiraphJobObserver
jobFinished
in interface GiraphJobObserver
jobToSubmit
- Job that ran in hadoop.passed
- true if job succeeded.public void jobGotAllMappers(org.apache.hadoop.mapreduce.Job job)
GiraphJobObserver
jobGotAllMappers
in interface GiraphJobObserver
job
- job that runsCopyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.