org.apache.giraph.utils

Class LogVersions

java.lang.Object

org.apache.giraph.utils.LogVersions

All Implemented Interfaces:

GiraphConfigurationSettable, ImmutableClassesGiraphConfigurable, MasterObserver, WorkerObserver

public class LogVersions
extends Object
implements WorkerObserver, MasterObserver

Logs versions of Giraph dependencies on job start.

Constructor Summary

Constructors

Constructor and Description
LogVersions()

Method Summary

Modifier and Type	Method and Description
void	applicationFailed(Exception e) If there is an error during the application.
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.
void	superstepMetricsUpdate(long superstep, AggregatedMetrics aggregatedMetrics, List<PartitionStats> partitionStatsList) Called after each superstep with aggregated metrics from workers

Methods inherited from class java.lang.Object

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

Constructor Detail

LogVersions

public LogVersions()

Method Detail

applicationFailed

public void applicationFailed(Exception e)

Description copied from interface: MasterObserver

If there is an error during the application.

Specified by:

applicationFailed in interface MasterObserver

Parameters:

e - Exception that caused failure. May be null.

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

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

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 MasterObserver

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 MasterObserver

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 MasterObserver

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 MasterObserver

Specified by:

postSuperstep in interface WorkerObserver

Parameters:

superstep - number of superstep

superstepMetricsUpdate

public void superstepMetricsUpdate(long superstep,
                                   AggregatedMetrics aggregatedMetrics,
                                   List<PartitionStats> partitionStatsList)

Description copied from interface: MasterObserver

Called after each superstep with aggregated metrics from workers

Specified by:

superstepMetricsUpdate in interface MasterObserver

Parameters:

superstep - Supsertep number

aggregatedMetrics - Metrics

partitionStatsList - List of partition stats