org.apache.giraph.graph

Class GlobalStats

java.lang.Object

org.apache.giraph.graph.GlobalStats

All Implemented Interfaces:

org.apache.hadoop.io.Writable

public class GlobalStats
extends Object
implements org.apache.hadoop.io.Writable

Aggregated stats by the master.

Constructor Summary

Constructors

Constructor and Description
GlobalStats()

Method Summary

Modifier and Type	Method and Description
void	addMessageBytesCount(long msgBytesCount) Add messages to the global stats.
void	addMessageCount(long messageCount) Add messages to the global stats.
void	addOocLoadBytesCount(long oocLoadBytesCount) Add bytes loaded to the global stats.
void	addOocStoreBytesCount(long oocStoreBytesCount) Add bytes stored to the global stats.
void	addPartitionStats(PartitionStats partitionStats) Add the stats of a partition to the global stats.
CheckpointStatus	getCheckpointStatus()
long	getEdgeCount()
long	getFinishedVertexCount()
boolean	getHaltComputation()
int	getLowestGraphPercentageInMemory()
long	getMessageBytesCount()
long	getMessageCount()
long	getOocLoadBytesCount()
long	getOocStoreBytesCount()
long	getVertexCount()
void	readFields(DataInput input)
void	setCheckpointStatus(CheckpointStatus checkpointStatus)
void	setHaltComputation(boolean value)
void	setLowestGraphPercentageInMemory(int lowestGraphPercentageInMemory)
String	toString()
void	write(DataOutput output)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

GlobalStats

public GlobalStats()

Method Detail

addPartitionStats

public void addPartitionStats(PartitionStats partitionStats)

Add the stats of a partition to the global stats.

Parameters:

partitionStats - Partition stats to be added.

getVertexCount

public long getVertexCount()

getFinishedVertexCount

public long getFinishedVertexCount()

getEdgeCount

public long getEdgeCount()

getMessageCount

public long getMessageCount()

getMessageBytesCount

public long getMessageBytesCount()

getHaltComputation

public boolean getHaltComputation()

setHaltComputation

public void setHaltComputation(boolean value)

getOocStoreBytesCount

public long getOocStoreBytesCount()

getOocLoadBytesCount

public long getOocLoadBytesCount()

getCheckpointStatus

public CheckpointStatus getCheckpointStatus()

setCheckpointStatus

public void setCheckpointStatus(CheckpointStatus checkpointStatus)

getLowestGraphPercentageInMemory

public int getLowestGraphPercentageInMemory()

setLowestGraphPercentageInMemory

public void setLowestGraphPercentageInMemory(int lowestGraphPercentageInMemory)

addOocLoadBytesCount

public void addOocLoadBytesCount(long oocLoadBytesCount)

Add bytes loaded to the global stats.

Parameters:

oocLoadBytesCount - number of bytes to be added

addOocStoreBytesCount

public void addOocStoreBytesCount(long oocStoreBytesCount)

Add bytes stored to the global stats.

Parameters:

oocStoreBytesCount - number of bytes to be added

addMessageCount

public void addMessageCount(long messageCount)

Add messages to the global stats.

Parameters:

messageCount - Number of messages to be added.

addMessageBytesCount

public void addMessageBytesCount(long msgBytesCount)

Add messages to the global stats.

Parameters:

msgBytesCount - Number of message bytes to be added.

readFields

public void readFields(DataInput input)
                throws IOException

Specified by:

readFields in interface org.apache.hadoop.io.Writable

Throws:

IOException

write

public void write(DataOutput output)
           throws IOException

Specified by:

write in interface org.apache.hadoop.io.Writable

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object