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(java.io.DataInputStream in)
           
 boolean equals(java.lang.Object other)
           
static long generateId()
           
 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(java.io.DataOutputStream 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()

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(java.io.DataOutputStream out)
               throws java.io.IOException
Throws:
java.io.IOException

deserialize

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