public interface GiraphJobObserver
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.
|
void launchingJob(org.apache.hadoop.mapreduce.Job jobToSubmit)
jobToSubmit
- Job we're going to submit to hadoop.void jobRunning(org.apache.hadoop.mapreduce.Job submittedJob)
submittedJob
- Job which was submitted.void jobFinished(org.apache.hadoop.mapreduce.Job submittedJob, boolean passed)
submittedJob
- Job that ran in hadoop.passed
- true if job succeeded.void jobGotAllMappers(org.apache.hadoop.mapreduce.Job job)
job
- job that runsCopyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.