Package org.apache.storm.tuple
Class MessageId
- java.lang.Object
-
- org.apache.storm.tuple.MessageId
-
public class MessageId extends Object
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static MessageId
deserialize(com.esotericsoftware.kryo.io.Input in)
boolean
equals(Object other)
static long
generateId(Random rand)
Set<Long>
getAnchors()
Map<Long,Long>
getAnchorsToIds()
int
hashCode()
static MessageId
makeId(Map<Long,Long> anchorsToIds)
static MessageId
makeRootId(long id, long val)
static MessageId
makeUnanchored()
void
serialize(com.esotericsoftware.kryo.io.Output out)
String
toString()
-
-
-
Method Detail
-
generateId
public static long generateId(Random rand)
-
makeUnanchored
public static MessageId makeUnanchored()
-
makeRootId
public static MessageId makeRootId(long id, long val)
-
deserialize
public static MessageId deserialize(com.esotericsoftware.kryo.io.Input in) throws IOException
- Throws:
IOException
-
serialize
public void serialize(com.esotericsoftware.kryo.io.Output out) throws IOException
- Throws:
IOException
-
-