org.apache.giraph.partition

Class PartitionStats

java.lang.Object

org.apache.giraph.partition.PartitionStats

All Implemented Interfaces:

org.apache.hadoop.io.Writable

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

Used to keep track of statistics of every Partition. Contains no actual partition data, only the statistics.

Constructor Summary

Constructors

Constructor and Description
PartitionStats() Default constructor for reflection.
PartitionStats(int partitionId, long vertexCount, long finishedVertexCount, long edgeCount, long messagesSentCount, long messageBytesSentCount, String workerHostnameId) Constructor with the initial stats.

Method Summary

Modifier and Type	Method and Description
void	addEdgeCount(long edgeCount) Add edges to the edge count.
void	addMessageBytesSentCount(long messageBytesSentCount) Add message bytes to messageBytesSentCount.
void	addMessagesSentCount(long messagesSentCount) Add messages to the messages sent count.
long	getComputeMs()
long	getEdgeCount() Get the edge count.
long	getFinishedVertexCount() Get the finished vertex count.
long	getMessageBytesSentCount() Get the message bytes sent count.
long	getMessagesSentCount() Get the messages sent count.
int	getPartitionId() Get partition id.
long	getVertexCount() Get the vertex count.
String	getWorkerHostnameId()
void	incrFinishedVertexCount() Increment the finished vertex count by one.
void	incrVertexCount() Increment the vertex count by one.
void	readFields(DataInput input)
void	setComputeMs(long computeMs)
void	setPartitionId(int partitionId) Set the partition id.
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

PartitionStats

public PartitionStats()

Default constructor for reflection.

PartitionStats

public PartitionStats(int partitionId,
                      long vertexCount,
                      long finishedVertexCount,
                      long edgeCount,
                      long messagesSentCount,
                      long messageBytesSentCount,
                      String workerHostnameId)

Constructor with the initial stats.

Parameters:

partitionId - Partition count.

vertexCount - Vertex count.

finishedVertexCount - Finished vertex count.

edgeCount - Edge count.

messagesSentCount - Number of messages sent

messageBytesSentCount - Number of message bytes sent

workerHostnameId - Hostname and id of worker owning this partition

Method Detail

setPartitionId

public void setPartitionId(int partitionId)

Set the partition id.

Parameters:

partitionId - New partition id.

getPartitionId

public int getPartitionId()

Get partition id.

Returns:

Partition id.

incrVertexCount

public void incrVertexCount()

Increment the vertex count by one.

getVertexCount

public long getVertexCount()

Get the vertex count.

Returns:

Vertex count.

incrFinishedVertexCount

public void incrFinishedVertexCount()

Increment the finished vertex count by one.

getFinishedVertexCount

public long getFinishedVertexCount()

Get the finished vertex count.

Returns:

Finished vertex count.

addEdgeCount

public void addEdgeCount(long edgeCount)

Add edges to the edge count.

Parameters:

edgeCount - Number of edges to add.

getEdgeCount

public long getEdgeCount()

Get the edge count.

Returns:

Edge count.

addMessagesSentCount

public void addMessagesSentCount(long messagesSentCount)

Add messages to the messages sent count.

Parameters:

messagesSentCount - Number of messages to add.

getMessagesSentCount

public long getMessagesSentCount()

Get the messages sent count.

Returns:

Messages sent count.

addMessageBytesSentCount

public void addMessageBytesSentCount(long messageBytesSentCount)

Add message bytes to messageBytesSentCount.

Parameters:

messageBytesSentCount - Number of message bytes to add.

getMessageBytesSentCount

public long getMessageBytesSentCount()

Get the message bytes sent count.

Returns:

Message bytes sent count.

getComputeMs

public long getComputeMs()

setComputeMs

public void setComputeMs(long computeMs)

getWorkerHostnameId

public String getWorkerHostnameId()

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