Package | Description |
---|---|
org.apache.giraph.master |
Package of all the master related things.
|
org.apache.giraph.metrics |
Package of all the Giraph metrics related data.
|
org.apache.giraph.utils |
Package of all generic utility classes.
|
Modifier and Type | Method and Description |
---|---|
void |
DefaultMasterObserver.superstepMetricsUpdate(long superstep,
AggregatedMetrics aggregatedMetrics,
List<PartitionStats> partitionStatsList) |
void |
MasterObserver.superstepMetricsUpdate(long superstep,
AggregatedMetrics aggregatedMetrics,
List<PartitionStats> partitionStatsList)
Called after each superstep with aggregated metrics from workers
|
Modifier and Type | Method and Description |
---|---|
AggregatedMetrics |
AggregatedMetrics.add(String name,
double value,
String hostnamePartitionId)
Add value from hostname for a metric.
|
AggregatedMetrics |
AggregatedMetrics.add(String name,
long value,
String hostnamePartitionId)
Add value from hostname for a metric.
|
AggregatedMetrics |
AggregatedMetrics.add(WorkerSuperstepMetrics workerMetrics,
String hostname)
Add metrics from worker.
|
AggregatedMetrics |
AggregatedMetrics.print(long superstep,
PrintStream out)
Print the aggregated metrics to the stream provided.
|
Modifier and Type | Method and Description |
---|---|
void |
LogVersions.superstepMetricsUpdate(long superstep,
AggregatedMetrics aggregatedMetrics,
List<PartitionStats> partitionStatsList) |
void |
ReactiveJMapHistoDumper.superstepMetricsUpdate(long superstep,
AggregatedMetrics aggregatedMetrics,
List<PartitionStats> partitionStatsList) |
void |
JMapHistoDumper.superstepMetricsUpdate(long superstep,
AggregatedMetrics aggregatedMetrics,
List<PartitionStats> partitionStatsList) |
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.