org.apache.giraph.worker

Class DefaultWorkerObserver

java.lang.Object

org.apache.giraph.worker.DefaultWorkerObserver

All Implemented Interfaces:

GiraphConfigurationSettable, ImmutableClassesGiraphConfigurable, WorkerObserver

public class DefaultWorkerObserver
extends Object
implements WorkerObserver

Default Observer for Worker that does nothing.

Constructor Summary

Constructors

Constructor and Description
DefaultWorkerObserver()

Method Summary

Modifier and Type	Method and Description
ImmutableClassesGiraphConfiguration	getConf() Return the configuration used by this object.
void	postApplication() Finalize the observer.
void	postSave() Finalize the observer.
void	postSuperstep(long superstep) Execute the observer.
void	preApplication() Initialize the observer.
void	preLoad() Initialize the observer.
void	preSuperstep(long superstep) Execute the observer.
void	setConf(ImmutableClassesGiraphConfiguration configuration) Set the configuration to be used by this object.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultWorkerObserver

public DefaultWorkerObserver()

Method Detail

preLoad

public void preLoad()

Description copied from interface: WorkerObserver

Initialize the observer. This method is executed once on each worker before loading.

Specified by:

preLoad in interface WorkerObserver

postSave

public void postSave()

Description copied from interface: WorkerObserver

Finalize the observer. This method is executed once on each worker after saving.

Specified by:

postSave in interface WorkerObserver

preApplication

public void preApplication()

Description copied from interface: WorkerObserver

Initialize the observer. This method is executed once on each worker after loading before the first superstep starts.

Specified by:

preApplication in interface WorkerObserver

postApplication

public void postApplication()

Description copied from interface: WorkerObserver

Finalize the observer. This method is executed once on each worker after the last superstep ends before saving.

Specified by:

postApplication in interface WorkerObserver

preSuperstep

public void preSuperstep(long superstep)

Description copied from interface: WorkerObserver

Execute the observer. This method is executed once on each worker before each superstep starts.

Specified by:

preSuperstep in interface WorkerObserver

Parameters:

superstep - number of superstep

postSuperstep

public void postSuperstep(long superstep)

Description copied from interface: WorkerObserver

Execute the observer. This method is executed once on each worker after each superstep ends.

Specified by:

postSuperstep in interface WorkerObserver

Parameters:

superstep - number of superstep

getConf

public ImmutableClassesGiraphConfiguration getConf()

Description copied from interface: ImmutableClassesGiraphConfigurable

Return the configuration used by this object.

Specified by:

getConf in interface ImmutableClassesGiraphConfigurable

Returns:

Set configuration

setConf

public void setConf(ImmutableClassesGiraphConfiguration configuration)

Description copied from interface: GiraphConfigurationSettable

Set the configuration to be used by this object.

Specified by:

setConf in interface GiraphConfigurationSettable

Parameters:

configuration - Set configuration