unipg.gila.common.datastructures.messagetypes

Class PartitionMessage

java.lang.Object

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

unipg.gila.common.datastructures.messagetypes.PartitionMessage

All Implemented Interfaces:

org.apache.hadoop.io.Writable

public class PartitionMessage
extends MessageWritable<java.lang.Long,java.lang.Short>

This class is used during the partitioning label propagation.

Author:

Alessio Arleo

Field Summary

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

payloadVertex, ttl, value

Constructor Summary

Constructors

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.

Method Summary

Methods

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

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

PartitionMessage

public PartitionMessage()

Parameter-less constructor.

PartitionMessage

public PartitionMessage(long payloadVertex,
                int ttl,
                short partition)

Creates a new Partition Message with ttl 0 with the specified ttl.

Parameters:

payloadVertex -

ttl -

partition -

PartitionMessage

public PartitionMessage(long payloadVertex,
                short partition)

Creates a new Partition Message with ttl 0.

Parameters:

payloadVertex -

partition -

Method Detail

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

propagate

public MessageWritable<java.lang.Long,java.lang.Short> 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.Short>

Returns:

A new MessageWritable with a decreased time to live.

propagateAndDie

public MessageWritable<java.lang.Long,java.lang.Short> 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.Short>

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.Short>

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.Short>

Throws:

java.io.IOException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object