org.apache.giraph.bsp.checkpoints

Class DisabledCheckpointSupportedChecker

java.lang.Object

org.apache.giraph.bsp.checkpoints.DisabledCheckpointSupportedChecker

All Implemented Interfaces:

CheckpointSupportedChecker

public class DisabledCheckpointSupportedChecker
extends Object
implements CheckpointSupportedChecker

Disable all checkpoints.

Constructor Summary

Constructors

Constructor and Description
DisabledCheckpointSupportedChecker()

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

DisabledCheckpointSupportedChecker

public DisabledCheckpointSupportedChecker()

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.