org.apache.giraph.master

Interface MasterObserver

All Superinterfaces:

GiraphConfigurationSettable, ImmutableClassesGiraphConfigurable

All Known Implementing Classes:

DefaultMasterObserver, JMapHistoDumper, LogVersions, ReactiveJMapHistoDumper

public interface MasterObserver
extends ImmutableClassesGiraphConfigurable

Observer for Master. It can implement ContextSettable if it needs to access job counters.

Method Summary

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

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

getConf

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

setConf

Method Detail

preApplication

void preApplication()

Before application begins.

postApplication

void postApplication()

After application ends.

applicationFailed

void applicationFailed(Exception e)

If there is an error during the application.

Parameters:

e - Exception that caused failure. May be null.

preSuperstep

void preSuperstep(long superstep)

Before each superstep starts.

Parameters:

superstep - The superstep number

postSuperstep

void postSuperstep(long superstep)

After each superstep ends.

Parameters:

superstep - The superstep number

superstepMetricsUpdate

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

Called after each superstep with aggregated metrics from workers

Parameters:

superstep - Supsertep number

aggregatedMetrics - Metrics

partitionStatsList - List of partition stats