org.apache.giraph.graph

Class GraphTaskManager.FailWithEveryExceptionOccurred

java.lang.Object

org.apache.giraph.graph.GraphTaskManager.FailWithEveryExceptionOccurred

All Implemented Interfaces:

GraphTaskManager.CheckerIfWorkerShouldFailAfterException

Enclosing class:

GraphTaskManager<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

public static class GraphTaskManager.FailWithEveryExceptionOccurred
extends Object
implements GraphTaskManager.CheckerIfWorkerShouldFailAfterException

Class to use by default, where each exception causes job failure

Constructor Summary

Constructors

Constructor and Description
FailWithEveryExceptionOccurred()

Method Summary

Modifier and Type	Method and Description
boolean	checkIfWorkerShouldFail(Thread thread, Throwable exception) Check if worker should fail after a thread gets an exception

Methods inherited from class java.lang.Object

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

Constructor Detail

FailWithEveryExceptionOccurred

public FailWithEveryExceptionOccurred()

Method Detail

checkIfWorkerShouldFail

public boolean checkIfWorkerShouldFail(Thread thread,
                                       Throwable exception)

Description copied from interface: GraphTaskManager.CheckerIfWorkerShouldFailAfterException

Check if worker should fail after a thread gets an exception

Specified by:

checkIfWorkerShouldFail in interface GraphTaskManager.CheckerIfWorkerShouldFailAfterException

Parameters:

thread - Thread which raised the exception

exception - Exception which occurred

Returns:

True iff worker should fail after this exception