org.apache.giraph.bsp.checkpoints

Class DefaultCheckpointSupportedChecker

java.lang.Object

org.apache.giraph.bsp.checkpoints.DefaultCheckpointSupportedChecker

All Implemented Interfaces:

CheckpointSupportedChecker

public class DefaultCheckpointSupportedChecker
extends Object
implements CheckpointSupportedChecker

Default checkpoint supported checker. Most tasks will support checkpointing by default unless they do output during the computation. Some tasks however can use non-checkpointable features, e.g.: static variables to pass data around between supersteps or new threads started from MasterCompute or external resources. In that case to prevent accidental checkpointing you should provide checker implementation.

Constructor Summary

Constructors

Constructor and Description
DefaultCheckpointSupportedChecker()

Method Summary

Modifier and Type	Method and Description
boolean	isCheckpointSupported(GiraphConfiguration conf, MasterCompute masterCompute) Does the job support checkpoints? It is true by default, set it to false if your job uses some non-checkpointable features: - static variables for storing data between supersteps.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultCheckpointSupportedChecker

public DefaultCheckpointSupportedChecker()

Method Detail

isCheckpointSupported

public boolean isCheckpointSupported(GiraphConfiguration conf,
                                     MasterCompute masterCompute)

Description copied from interface: CheckpointSupportedChecker

Does the job support checkpoints? It is true by default, set it to false if your job uses some non-checkpointable features: - static variables for storing data between supersteps. - starts new threads or uses Timers - writes output before job is complete, etc This method is called on master and has access to job configuration and master compute.

Specified by:

isCheckpointSupported in interface CheckpointSupportedChecker

Parameters:

conf - giraph configuration

masterCompute - instance of master compute

Returns:

true if checkpointing on current superstep is supported by this application.