unipg.gila.common.datastructures.messagetypes

Class DegMessage

java.lang.Object

unipg.gila.common.datastructures.messagetypes.MessageWritable<java.lang.Long,java.lang.Integer>

unipg.gila.common.datastructures.messagetypes.DegMessage

All Implemented Interfaces:

org.apache.hadoop.io.Writable

public class DegMessage
extends MessageWritable<java.lang.Long,java.lang.Integer>

This kind of message is used to prune the one degree messages and carries the degree of the generating vertex.

Author:

Alessio Arleo

Field Summary

Fields inherited from class unipg.gila.common.datastructures.messagetypes.MessageWritable

payloadVertex, ttl, value

Constructor Summary

Constructors

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)

Method Summary

Methods

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()

Methods inherited from class unipg.gila.common.datastructures.messagetypes.MessageWritable

getPayloadVertex, getTTL, getValue, isAZombie, readFields, setValue, write

Methods inherited from class java.lang.Object

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

Constructor Detail

DegMessage

public DegMessage()

Parameter-less constructor.

DegMessage

public DegMessage(int ttl,
          long payloadVertex,
          int deg)

DegMessage

public DegMessage(long payloadVertex,
          int deg)

Constructor setting only payload vertex id and the value of the message, leaving ttl to 0.

Parameters:

payloadVertex -

deg -

DegMessage

public DegMessage(long payloadVertex,
          int component,
          int deg)

DegMessage

public DegMessage(long sourceId,
          int ttl,
          int component,
          int deg)

Method Detail

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

getComponent

public long getComponent()

Returns the component of the vertex who sent this message.

Returns:

The connect component id of the vertex who sent this message.

propagate

public MessageWritable<java.lang.Long,java.lang.Integer> propagate()

Description copied from class: MessageWritable

This method propagates the message by creating a new MessageWritable and copying the containing values. The returning message will have its time to live diminished.

Specified by:

propagate in class MessageWritable<java.lang.Long,java.lang.Integer>

Returns:

A new MessageWritable with a decreased time to live.

propagateAndDie

public MessageWritable<java.lang.Long,java.lang.Integer> propagateAndDie()

Description copied from class: MessageWritable

This method propagates the message by creating a new MessageWritable and copying the containing values. The returning message will have its time to live zero so that it is scrapped at the next superstep.

Specified by:

propagateAndDie in class MessageWritable<java.lang.Long,java.lang.Integer>

Returns:

A new MessageWritable with a decreased time to live equal to zero.

specificRead

public void specificRead(java.io.DataInput input)
                  throws java.io.IOException

Description copied from class: MessageWritable

Method that guarantees that extending classes are serialized properly. All instance variables (excluding the ttl) must be serialized in this method (payloadVertex, value and any other variable introduced). To know more about the serializing process in Hadoop please visit this website.

Specified by:

specificRead in class MessageWritable<java.lang.Long,java.lang.Integer>

Throws:

java.io.IOException

specificWrite

public void specificWrite(java.io.DataOutput output)
                   throws java.io.IOException

Description copied from class: MessageWritable

Method that guarantees that extending classes are de-serialized properly. All instance variables (excluding the ttl) must be de-serialized in this method (payloadVertex, value and any other variable introduced). To know more about the serializing process in Hadoop please visit this website.

Specified by:

specificWrite in class MessageWritable<java.lang.Long,java.lang.Integer>

Throws:

java.io.IOException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object