public class JMapHistoDumper extends Object implements MasterObserver, WorkerObserver
Constructor and Description |
---|
JMapHistoDumper() |
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 |
postSave()
Finalize the observer.
|
void |
postSuperstep(long superstep)
After each superstep ends.
|
void |
preApplication()
Before application begins.
|
void |
preLoad()
Initialize the observer.
|
void |
preSuperstep(long superstep)
Before each superstep starts.
|
void |
setConf(ImmutableClassesGiraphConfiguration configuration)
Set the configuration to be used by this object.
|
void |
startJMapThread()
Start the jmap thread
|
void |
superstepMetricsUpdate(long superstep,
AggregatedMetrics aggregatedMetrics,
List<PartitionStats> partitionStatsList)
Called after each superstep with aggregated metrics from workers
|
public void preLoad()
WorkerObserver
preLoad
in interface WorkerObserver
public void postSave()
WorkerObserver
postSave
in interface WorkerObserver
public void preApplication()
MasterObserver
preApplication
in interface MasterObserver
preApplication
in interface WorkerObserver
public void postApplication()
MasterObserver
postApplication
in interface MasterObserver
postApplication
in interface WorkerObserver
public void startJMapThread()
public void preSuperstep(long superstep)
MasterObserver
preSuperstep
in interface MasterObserver
preSuperstep
in interface WorkerObserver
superstep
- The superstep numberpublic void postSuperstep(long superstep)
MasterObserver
postSuperstep
in interface MasterObserver
postSuperstep
in interface WorkerObserver
superstep
- The superstep numberpublic void superstepMetricsUpdate(long superstep, AggregatedMetrics aggregatedMetrics, List<PartitionStats> partitionStatsList)
MasterObserver
superstepMetricsUpdate
in interface MasterObserver
superstep
- Supsertep numberaggregatedMetrics
- MetricspartitionStatsList
- List of partition statspublic void applicationFailed(Exception e)
MasterObserver
applicationFailed
in interface MasterObserver
e
- Exception that caused failure. May be null.public void setConf(ImmutableClassesGiraphConfiguration configuration)
GiraphConfigurationSettable
setConf
in interface GiraphConfigurationSettable
configuration
- Set configurationpublic ImmutableClassesGiraphConfiguration getConf()
ImmutableClassesGiraphConfigurable
getConf
in interface ImmutableClassesGiraphConfigurable
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.