org.apache.giraph.job

Class DefaultGiraphJobRetryChecker

java.lang.Object

org.apache.giraph.job.DefaultGiraphJobRetryChecker

All Implemented Interfaces:

GiraphJobRetryChecker

public class DefaultGiraphJobRetryChecker
extends Object
implements GiraphJobRetryChecker

Default implementation of GiraphJobRetryChecker, which never retries the job.

Constructor Summary

Constructors

Constructor and Description
DefaultGiraphJobRetryChecker()

Method Summary

Modifier and Type	Method and Description
String	shouldRestartCheckpoint(org.apache.hadoop.mapreduce.Job lastAttempt) The job has been checkpointed and halted.
boolean	shouldRetry(org.apache.hadoop.mapreduce.Job submittedJob, int tryCount) Check if the job should be retried

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultGiraphJobRetryChecker

public DefaultGiraphJobRetryChecker()

Method Detail

shouldRetry

public boolean shouldRetry(org.apache.hadoop.mapreduce.Job submittedJob,
                           int tryCount)

Description copied from interface: GiraphJobRetryChecker

Check if the job should be retried

Specified by:

shouldRetry in interface GiraphJobRetryChecker

Parameters:

submittedJob - Job that ran and failed

tryCount - How many times have we tried to run the job until now

Returns:

True iff job should be retried

shouldRestartCheckpoint

public String shouldRestartCheckpoint(org.apache.hadoop.mapreduce.Job lastAttempt)

Description copied from interface: GiraphJobRetryChecker

The job has been checkpointed and halted. Should we now restart it?

Specified by:

shouldRestartCheckpoint in interface GiraphJobRetryChecker

Parameters:

lastAttempt - latest failed job

Returns:

JobID of job to be restarted or null if we don't want to restart anything