public class DegMessage extends MessageWritable<java.lang.Long,java.lang.Integer>
payloadVertex, ttl, value
Constructor and Description |
---|
DegMessage()
Parameter-less constructor.
|
DegMessage(int ttl,
long payloadVertex,
int deg) |
DegMessage(long payloadVertex,
int deg)
Constructor setting only payload vertex id and the value of the message, leaving ttl to 0.
|
DegMessage(long payloadVertex,
int component,
int deg) |
DegMessage(long sourceId,
int ttl,
int component,
int deg) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(java.lang.Object o) |
long |
getComponent()
Returns the component of the vertex who sent this message.
|
MessageWritable<java.lang.Long,java.lang.Integer> |
propagate()
This method propagates the message by creating a new MessageWritable and copying the containing values.
|
MessageWritable<java.lang.Long,java.lang.Integer> |
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 DegMessage()
public DegMessage(int ttl, long payloadVertex, int deg)
public DegMessage(long payloadVertex, int deg)
payloadVertex
- deg
- public DegMessage(long payloadVertex, int component, int deg)
public DegMessage(long sourceId, int ttl, int component, int deg)
public boolean equals(java.lang.Object o)
equals
in class java.lang.Object
public long getComponent()
public MessageWritable<java.lang.Long,java.lang.Integer> propagate()
MessageWritable
propagate
in class MessageWritable<java.lang.Long,java.lang.Integer>
public MessageWritable<java.lang.Long,java.lang.Integer> propagateAndDie()
MessageWritable
propagateAndDie
in class MessageWritable<java.lang.Long,java.lang.Integer>
public void specificRead(java.io.DataInput input) throws java.io.IOException
MessageWritable
specificRead
in class MessageWritable<java.lang.Long,java.lang.Integer>
java.io.IOException
public void specificWrite(java.io.DataOutput output) throws java.io.IOException
MessageWritable
specificWrite
in class MessageWritable<java.lang.Long,java.lang.Integer>
java.io.IOException
public java.lang.String toString()
toString
in class java.lang.Object