org.apache.giraph.comm.messages.queue

Class PartitionMessage<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>

java.lang.Object

org.apache.giraph.comm.messages.queue.PartitionMessage<I,M>

Type Parameters:

I - vertexId type parameter

M - message type parameter

public class PartitionMessage<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>
extends Object

Small wrapper that holds a reference to vertex message and knows partition id.

Constructor Summary

Constructors

Constructor and Description
PartitionMessage(int partitionId, VertexIdMessages<I,M> message) Constructs wrapper from partitino id and vertext message object.

Method Summary

Modifier and Type	Method and Description
VertexIdMessages<I,M>	getMessage() Message
int	getPartitionId() Partition id
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

PartitionMessage

public PartitionMessage(int partitionId,
                        VertexIdMessages<I,M> message)

Constructs wrapper from partitino id and vertext message object.

Parameters:

partitionId - destination partition id

message - message object

Method Detail

getPartitionId

public int getPartitionId()

Partition id

Returns:

destination partition id.

getMessage

public VertexIdMessages<I,M> getMessage()

Message

Returns:

vertex message

toString

public String toString()

Overrides:

toString in class Object