public class GiraphStats extends HadoopCountersBase
Modifier and Type | Field and Description |
---|---|
static String |
AGGREGATE_SENT_MESSAGE_BYTES_NAME
aggregate sent messages bytes counter name
|
static String |
AGGREGATE_SENT_MESSAGES_NAME
aggregate sent messages counter name
|
static String |
CURRENT_MASTER_PARTITION_TASK_NAME
current master partition task counter name
|
static String |
CURRENT_WORKERS_NAME
workers counter name
|
static String |
EDGES_NAME
aggregate edges counter name
|
static String |
FINISHED_VERTICES_NAME
aggregate finished vertices counter name
|
static String |
GROUP_NAME
Counter group name for the Giraph statistics
|
static String |
LAST_CHECKPOINTED_SUPERSTEP_NAME
last checkpointed superstep counter name
|
static String |
LOWEST_GRAPH_PERCENTAGE_IN_MEMORY_NAME
lowest percentage of graph in memory throughout the execution
|
static String |
OOC_BYTES_LOADED_NAME
aggregate bytes loaded from local disks in out-of-core
|
static String |
OOC_BYTES_STORED_NAME
aggregate bytes stored to local disks in out-of-core
|
static String |
SENT_MESSAGE_BYTES_NAME
sent message bytes counter name
|
static String |
SENT_MESSAGES_NAME
sent messages counter name
|
static String |
SUPERSTEP_NAME
superstep counter name
|
static String |
VERTICES_NAME
aggregate vertices counter name
|
Modifier and Type | Method and Description |
---|---|
GiraphHadoopCounter |
getAggregateOOCBytesLoaded()
Get OOCBytesLoaded counter
|
GiraphHadoopCounter |
getAggregateOOCBytesStored()
Get OOCBytesStored counter
|
GiraphHadoopCounter |
getAggregateSentMessageBytes()
Get AggregateSentMessageBytes counter
|
GiraphHadoopCounter |
getAggregateSentMessages()
Get AggregateSentMessages counter
|
List<CustomCounter> |
getCounterList()
Get a map of counter names, and values
To be used by the master to send to the job client
|
GiraphHadoopCounter |
getCurrentMasterTaskPartition()
Get CurrentMasterTaskPartition counter
|
GiraphHadoopCounter |
getCurrentWorkers()
Get CurrentWorkers counter
|
GiraphHadoopCounter |
getEdges()
Get Edges counter
|
GiraphHadoopCounter |
getFinishedVertexes()
Get FinishedVertexes counter
|
static GiraphStats |
getInstance()
Get singleton instance.
|
GiraphHadoopCounter |
getLastCheckpointedSuperstep()
Get LastCheckpointedSuperstep counter
|
GiraphHadoopCounter |
getLowestGraphPercentageInMemory() |
GiraphHadoopCounter |
getSentMessageBytes()
Get SentMessageBytes counter
|
GiraphHadoopCounter |
getSentMessages()
Get SentMessages counter
|
GiraphHadoopCounter |
getSuperstepCounter()
Get SuperstepCounter counter
|
GiraphHadoopCounter |
getVertices()
Get Vertices counter
|
static void |
init(org.apache.hadoop.mapreduce.Mapper.Context context)
Initialize with Hadoop Context.
|
Iterator<GiraphHadoopCounter> |
iterator() |
getContext, getCounter
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEach, spliterator
public static final String GROUP_NAME
public static final String SUPERSTEP_NAME
public static final String VERTICES_NAME
public static final String FINISHED_VERTICES_NAME
public static final String EDGES_NAME
public static final String SENT_MESSAGES_NAME
public static final String SENT_MESSAGE_BYTES_NAME
public static final String AGGREGATE_SENT_MESSAGES_NAME
public static final String AGGREGATE_SENT_MESSAGE_BYTES_NAME
public static final String CURRENT_WORKERS_NAME
public static final String CURRENT_MASTER_PARTITION_TASK_NAME
public static final String LAST_CHECKPOINTED_SUPERSTEP_NAME
public static final String OOC_BYTES_LOADED_NAME
public static final String OOC_BYTES_STORED_NAME
public static final String LOWEST_GRAPH_PERCENTAGE_IN_MEMORY_NAME
public static void init(org.apache.hadoop.mapreduce.Mapper.Context context)
context
- Hadoop Context to use.public static GiraphStats getInstance()
public List<CustomCounter> getCounterList()
public GiraphHadoopCounter getSuperstepCounter()
public GiraphHadoopCounter getVertices()
public GiraphHadoopCounter getFinishedVertexes()
public GiraphHadoopCounter getEdges()
public GiraphHadoopCounter getSentMessages()
public GiraphHadoopCounter getSentMessageBytes()
public GiraphHadoopCounter getAggregateSentMessages()
public GiraphHadoopCounter getAggregateSentMessageBytes()
public GiraphHadoopCounter getCurrentWorkers()
public GiraphHadoopCounter getCurrentMasterTaskPartition()
public GiraphHadoopCounter getLastCheckpointedSuperstep()
public GiraphHadoopCounter getAggregateOOCBytesLoaded()
public GiraphHadoopCounter getAggregateOOCBytesStored()
public GiraphHadoopCounter getLowestGraphPercentageInMemory()
public Iterator<GiraphHadoopCounter> iterator()
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.