Package | Description |
---|---|
org.apache.storm.tuple |
Modifier and Type | Method and Description |
---|---|
static MessageId |
MessageId.deserialize(com.esotericsoftware.kryo.io.Input in) |
MessageId |
Tuple.getMessageId()
Gets the message id that associated with this tuple.
|
MessageId |
TupleImpl.getMessageId() |
static MessageId |
MessageId.makeId(Map<Long,Long> anchorsToIds) |
static MessageId |
MessageId.makeRootId(long id,
long val) |
static MessageId |
MessageId.makeUnanchored() |
Constructor and Description |
---|
TupleImpl(GeneralTopologyContext context,
List<Object> values,
String srcComponent,
int taskId,
String streamId,
MessageId id) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.