org.apache.giraph.worker

Interface WorkerObserver

All Superinterfaces:

GiraphConfigurationSettable, ImmutableClassesGiraphConfigurable

All Known Implementing Classes:

DefaultWorkerObserver, JMapHistoDumper, LogVersions, ReactiveJMapHistoDumper

public interface WorkerObserver
extends ImmutableClassesGiraphConfigurable

Observer for worker. The user can subclass and register an observer with the Giraph framework. The framework will execute methods of the observer at designated moments of computation on each worker. It can implement ContextSettable if it needs to access job counters.

Method Summary

Modifier and Type	Method and Description
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.

Methods inherited from interface org.apache.giraph.conf.ImmutableClassesGiraphConfigurable

getConf

Methods inherited from interface org.apache.giraph.conf.GiraphConfigurationSettable

setConf

Method Detail

preLoad

void preLoad()

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

preApplication

void preApplication()

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

preSuperstep

void preSuperstep(long superstep)

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

Parameters:

superstep - number of superstep

postSuperstep

void postSuperstep(long superstep)

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

Parameters:

superstep - number of superstep

postApplication

void postApplication()

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

postSave

void postSave()

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