public interface Tuple
Storm needs to know how to serialize all the values in a tuple. By default, Storm knows how to serialize the primitive types, strings, and byte arrays. If you want to use another type, you'll need to implement and register a serializer for that type.
Modifier and Type | Method and Description |
---|---|
boolean |
contains(java.lang.String field)
Returns true if this tuple contains the specified name of the field.
|
int |
fieldIndex(java.lang.String field)
Returns the position of the specified field in this tuple.
|
byte[] |
getBinary(int i)
Returns the byte array at position i in the tuple.
|
byte[] |
getBinaryByField(java.lang.String field) |
java.lang.Boolean |
getBoolean(int i)
Returns the Boolean at position i in the tuple.
|
java.lang.Boolean |
getBooleanByField(java.lang.String field) |
java.lang.Byte |
getByte(int i)
Returns the Byte at position i in the tuple.
|
java.lang.Byte |
getByteByField(java.lang.String field) |
java.lang.Double |
getDouble(int i)
Returns the Double at position i in the tuple.
|
java.lang.Double |
getDoubleByField(java.lang.String field) |
Fields |
getFields()
Gets the names of the fields in this tuple.
|
java.lang.Float |
getFloat(int i)
Returns the Float at position i in the tuple.
|
java.lang.Float |
getFloatByField(java.lang.String field) |
java.lang.Integer |
getInteger(int i)
Returns the Integer at position i in the tuple.
|
java.lang.Integer |
getIntegerByField(java.lang.String field) |
java.lang.Long |
getLong(int i)
Returns the Long at position i in the tuple.
|
java.lang.Long |
getLongByField(java.lang.String field) |
java.lang.Short |
getShort(int i)
Returns the Short at position i in the tuple.
|
java.lang.Short |
getShortByField(java.lang.String field) |
java.lang.String |
getSourceComponent()
Gets the id of the component that created this tuple.
|
java.lang.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.
|
java.lang.String |
getString(int i)
Returns the String at position i in the tuple.
|
java.lang.String |
getStringByField(java.lang.String field) |
java.lang.Object |
getValue(int i)
Gets the field at position i in the tuple.
|
java.lang.Object |
getValueByField(java.lang.String field) |
java.util.List<java.lang.Object> |
getValues()
Gets all the values in this tuple.
|
void |
resetValues()
Resets the tuple values to null
TODO:- Is this needed
|
java.util.List<java.lang.Object> |
select(Fields selector)
Returns a subset of the tuple based on the fields selector.
|
int |
size()
Returns the number of fields in this tuple.
|
int size()
int fieldIndex(java.lang.String field)
boolean contains(java.lang.String field)
java.lang.Object getValue(int i)
java.lang.String getString(int i)
java.lang.Integer getInteger(int i)
java.lang.Long getLong(int i)
java.lang.Boolean getBoolean(int i)
java.lang.Short getShort(int i)
java.lang.Byte getByte(int i)
java.lang.Double getDouble(int i)
java.lang.Float getFloat(int i)
byte[] getBinary(int i)
java.lang.Object getValueByField(java.lang.String field)
java.lang.String getStringByField(java.lang.String field)
java.lang.Integer getIntegerByField(java.lang.String field)
java.lang.Long getLongByField(java.lang.String field)
java.lang.Boolean getBooleanByField(java.lang.String field)
java.lang.Short getShortByField(java.lang.String field)
java.lang.Byte getByteByField(java.lang.String field)
java.lang.Double getDoubleByField(java.lang.String field)
java.lang.Float getFloatByField(java.lang.String field)
byte[] getBinaryByField(java.lang.String field)
java.util.List<java.lang.Object> getValues()
Fields getFields()
java.util.List<java.lang.Object> select(Fields selector)
java.lang.String getSourceComponent()
int getSourceTask()
java.lang.String getSourceStreamId()
void resetValues()