public class PartitionMessage extends MessageWritable<java.lang.Long,java.lang.Short>
payloadVertex, ttl, value
Constructor and Description |
---|
PartitionMessage()
Parameter-less constructor.
|
PartitionMessage(long payloadVertex,
int ttl,
short partition)
Creates a new Partition Message with ttl 0 with the specified ttl.
|
PartitionMessage(long payloadVertex,
short partition)
Creates a new Partition Message with ttl 0.
|
Modifier and Type | Method and Description |
---|---|
boolean |
equals(java.lang.Object o) |
MessageWritable<java.lang.Long,java.lang.Short> |
propagate()
This method propagates the message by creating a new MessageWritable and copying the containing values.
|
MessageWritable<java.lang.Long,java.lang.Short> |
propagateAndDie()
This method propagates the message by creating a new MessageWritable and copying the containing values.
|
void |
specificRead(java.io.DataInput input)
Method that guarantees that extending classes are serialized properly.
|
void |
specificWrite(java.io.DataOutput output)
Method that guarantees that extending classes are de-serialized properly.
|
java.lang.String |
toString() |
getPayloadVertex, getTTL, getValue, isAZombie, readFields, setValue, write
public PartitionMessage()
public PartitionMessage(long payloadVertex, int ttl, short partition)
payloadVertex
- ttl
- partition
- public PartitionMessage(long payloadVertex, short partition)
payloadVertex
- partition
- public boolean equals(java.lang.Object o)
equals
in class java.lang.Object
public MessageWritable<java.lang.Long,java.lang.Short> propagate()
MessageWritable
propagate
in class MessageWritable<java.lang.Long,java.lang.Short>
public MessageWritable<java.lang.Long,java.lang.Short> propagateAndDie()
MessageWritable
propagateAndDie
in class MessageWritable<java.lang.Long,java.lang.Short>
public void specificRead(java.io.DataInput input) throws java.io.IOException
MessageWritable
specificRead
in class MessageWritable<java.lang.Long,java.lang.Short>
java.io.IOException
public void specificWrite(java.io.DataOutput output) throws java.io.IOException
MessageWritable
specificWrite
in class MessageWritable<java.lang.Long,java.lang.Short>
java.io.IOException
public java.lang.String toString()
toString
in class java.lang.Object