org.apache.giraph.master

Class DefaultMasterObserver

java.lang.Object

org.apache.giraph.master.DefaultMasterObserver

All Implemented Interfaces:

GiraphConfigurationSettable, ImmutableClassesGiraphConfigurable, MasterObserver

public class DefaultMasterObserver
extends Object
implements MasterObserver

A no-op implementation of MasterObserver to make it easier for users.

Constructor Summary

Constructors

Constructor and Description
DefaultMasterObserver()

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() After application ends.
void	postSuperstep(long superstep) After each superstep ends.
void	preApplication() Before application begins.
void	preSuperstep(long superstep) Before each superstep starts.
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

DefaultMasterObserver

public DefaultMasterObserver()

Method Detail

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

preApplication

public void preApplication()

Description copied from interface: MasterObserver

Before application begins.

Specified by:

preApplication in interface MasterObserver

postApplication

public void postApplication()

Description copied from interface: MasterObserver

After application ends.

Specified by:

postApplication in interface MasterObserver

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.

preSuperstep

public void preSuperstep(long superstep)

Description copied from interface: MasterObserver

Before each superstep starts.

Specified by:

preSuperstep in interface MasterObserver

Parameters:

superstep - The superstep number

postSuperstep

public void postSuperstep(long superstep)

Description copied from interface: MasterObserver

After each superstep ends.

Specified by:

postSuperstep in interface MasterObserver

Parameters:

superstep - The superstep number

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