backtype.storm.tuple
Class MessageId

java.lang.Object
  extended by backtype.storm.tuple.MessageId

public class MessageId
extends java.lang.Object


Constructor Summary
protected MessageId(java.util.Map<java.lang.Long,java.lang.Long> anchorsToIds)
           
 
Method Summary
static MessageId deserialize(Input in)
           
 boolean equals(java.lang.Object other)
           
static long generateId(java.util.Random rand)
           
 java.util.Set<java.lang.Long> getAnchors()
           
 java.util.Map<java.lang.Long,java.lang.Long> getAnchorsToIds()
           
 int hashCode()
           
static MessageId makeId(java.util.Map<java.lang.Long,java.lang.Long> anchorsToIds)
           
static MessageId makeRootId(long id, long val)
           
static MessageId makeUnanchored()
           
 void serialize(Output out)
           
 java.lang.String toString()
           
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 

Constructor Detail

MessageId

protected MessageId(java.util.Map<java.lang.Long,java.lang.Long> anchorsToIds)
Method Detail

generateId

public static long generateId(java.util.Random rand)

makeUnanchored

public static MessageId makeUnanchored()

makeId

public static MessageId makeId(java.util.Map<java.lang.Long,java.lang.Long> anchorsToIds)

makeRootId

public static MessageId makeRootId(long id,
                                   long val)

getAnchorsToIds

public java.util.Map<java.lang.Long,java.lang.Long> getAnchorsToIds()

getAnchors

public java.util.Set<java.lang.Long> getAnchors()

hashCode

public int hashCode()
Overrides:
hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object other)
Overrides:
equals in class java.lang.Object

toString

public java.lang.String toString()
Overrides:
toString in class java.lang.Object

serialize

public void serialize(Output out)
               throws java.io.IOException
Throws:
java.io.IOException

deserialize

public static MessageId deserialize(Input in)
                             throws java.io.IOException
Throws:
java.io.IOException