public class ReactiveJMapHistoDumper extends DefaultImmutableClassesGiraphConfigurable implements MasterObserver, WorkerObserver
Constructor and Description |
---|
ReactiveJMapHistoDumper() |
Modifier and Type | Method and Description |
---|---|
void |
applicationFailed(Exception e)
If there is an error during the application.
|
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 |
startSupervisorThread()
Start the supervisor thread
|
void |
superstepMetricsUpdate(long superstep,
AggregatedMetrics aggregatedMetrics,
List<PartitionStats> partitionStatsList)
Called after each superstep with aggregated metrics from workers
|
getConf
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getConf
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 startSupervisorThread()
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
setConf
in class DefaultImmutableClassesGiraphConfigurable
configuration
- Set configurationCopyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.