public interface Tuple extends ITuple
http://github.com/nathanmarz/storm/wiki/Serialization
for more info.Modifier and Type | Method and Description |
---|---|
MessageId |
getMessageId()
Gets the message id that associated with this tuple.
|
String |
getSourceComponent()
Gets the id of the component that created this tuple.
|
GlobalStreamId |
getSourceGlobalStreamid()
Returns the global stream id (component + stream) of this tuple.
|
String |
getSourceStreamId()
Gets the id of the stream that this tuple was emitted to.
|
int |
getSourceTask()
Gets the id of the task that created this tuple.
|
contains, fieldIndex, getBinary, getBinaryByField, getBoolean, getBooleanByField, getByte, getByteByField, getDouble, getDoubleByField, getFields, getFloat, getFloatByField, getInteger, getIntegerByField, getLong, getLongByField, getShort, getShortByField, getString, getStringByField, getValue, getValueByField, getValues, select, size
GlobalStreamId getSourceGlobalStreamid()
String getSourceComponent()
int getSourceTask()
String getSourceStreamId()
MessageId getMessageId()
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.