public interface MasterObserver extends ImmutableClassesGiraphConfigurable
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
|
getConf
setConf
void preApplication()
void postApplication()
void applicationFailed(Exception e)
e
- Exception that caused failure. May be null.void preSuperstep(long superstep)
superstep
- The superstep numbervoid postSuperstep(long superstep)
superstep
- The superstep numbervoid superstepMetricsUpdate(long superstep, AggregatedMetrics aggregatedMetrics, List<PartitionStats> partitionStatsList)
superstep
- Supsertep numberaggregatedMetrics
- MetricspartitionStatsList
- List of partition statsCopyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.