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)
Gets the Byte array field with a specific name.
|
java.lang.Boolean |
getBoolean(int i)
Returns the Boolean at position i in the tuple.
|
java.lang.Boolean |
getBooleanByField(java.lang.String field)
Gets the Boolean field with a specific name.
|
java.lang.Byte |
getByte(int i)
Returns the Byte at position i in the tuple.
|
java.lang.Byte |
getByteByField(java.lang.String field)
Gets the Byte field with a specific name.
|
java.lang.Double |
getDouble(int i)
Returns the Double at position i in the tuple.
|
java.lang.Double |
getDoubleByField(java.lang.String field)
Gets the Double field with a specific name.
|
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)
Gets the Float field with a specific name.
|
java.lang.Integer |
getInteger(int i)
Returns the Integer at position i in the tuple.
|
java.lang.Integer |
getIntegerByField(java.lang.String field)
Gets the Integer field with a specific name.
|
java.lang.Long |
getLong(int i)
Returns the Long at position i in the tuple.
|
java.lang.Long |
getLongByField(java.lang.String field)
Gets the Long field with a specific name.
|
java.lang.Short |
getShort(int i)
Returns the Short at position i in the tuple.
|
java.lang.Short |
getShortByField(java.lang.String field)
Gets the Short field with a specific name.
|
java.lang.String |
getSourceComponent()
Gets the id of the component that created this tuple.
|
GlobalStreamId |
getSourceGlobalStreamId()
Returns the global stream id (component + stream) of 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)
Gets the String field with a specific name.
|
java.lang.Object |
getValue(int i)
Gets the field at position i in the tuple.
|
java.lang.Object |
getValueByField(java.lang.String field)
Gets the field with a specific name.
|
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()
boolean contains(java.lang.String field)
Fields getFields()
int fieldIndex(java.lang.String field)
java.lang.IllegalArgumentException
- - if field does not existjava.util.List<java.lang.Object> select(Fields selector)
java.lang.Object getValue(int i)
java.lang.IndexOutOfBoundsException
- - if the index is out of range `(index < 0 || index >= size())`java.lang.String getString(int i)
java.lang.ClassCastException
- If that field is not a Stringjava.lang.IndexOutOfBoundsException
- - if the index is out of range `(index < 0 || index >= size())`java.lang.Integer getInteger(int i)
java.lang.ClassCastException
- If that field is not a Integerjava.lang.IndexOutOfBoundsException
- - if the index is out of range `(index < 0 || index >= size())`java.lang.Long getLong(int i)
java.lang.ClassCastException
- If that field is not a Longjava.lang.IndexOutOfBoundsException
- - if the index is out of range `(index < 0 || index >= size())`java.lang.Boolean getBoolean(int i)
java.lang.ClassCastException
- If that field is not a Booleanjava.lang.IndexOutOfBoundsException
- - if the index is out of range `(index < 0 || index >= size())`java.lang.Short getShort(int i)
java.lang.ClassCastException
- If that field is not a Shortjava.lang.IndexOutOfBoundsException
- - if the index is out of range `(index < 0 || index >= size())`java.lang.Byte getByte(int i)
java.lang.ClassCastException
- If that field is not a Bytejava.lang.IndexOutOfBoundsException
- - if the index is out of range `(index < 0 || index >= size())`java.lang.Double getDouble(int i)
java.lang.ClassCastException
- If that field is not a Doublejava.lang.IndexOutOfBoundsException
- - if the index is out of range `(index < 0 || index >= size())`java.lang.Float getFloat(int i)
java.lang.ClassCastException
- If that field is not a Floatjava.lang.IndexOutOfBoundsException
- - if the index is out of range `(index < 0 || index >= size())`byte[] getBinary(int i)
java.lang.ClassCastException
- If that field is not a byte arrayjava.lang.IndexOutOfBoundsException
- - if the index is out of range `(index < 0 || index >= size())`java.lang.Object getValueByField(java.lang.String field)
java.lang.IllegalArgumentException
- - if field does not existjava.lang.String getStringByField(java.lang.String field)
java.lang.ClassCastException
- If that field is not a Stringjava.lang.IllegalArgumentException
- - if field does not existjava.lang.Integer getIntegerByField(java.lang.String field)
java.lang.ClassCastException
- If that field is not an Integerjava.lang.IllegalArgumentException
- - if field does not existjava.lang.Long getLongByField(java.lang.String field)
java.lang.ClassCastException
- If that field is not a Longjava.lang.IllegalArgumentException
- - if field does not existjava.lang.Boolean getBooleanByField(java.lang.String field)
java.lang.ClassCastException
- If that field is not a Booleanjava.lang.IllegalArgumentException
- - if field does not existjava.lang.Short getShortByField(java.lang.String field)
java.lang.ClassCastException
- If that field is not a Shortjava.lang.IllegalArgumentException
- - if field does not existjava.lang.Byte getByteByField(java.lang.String field)
java.lang.ClassCastException
- If that field is not a Bytejava.lang.IllegalArgumentException
- - if field does not existjava.lang.Double getDoubleByField(java.lang.String field)
java.lang.ClassCastException
- If that field is not a Doublejava.lang.IllegalArgumentException
- - if field does not existjava.lang.Float getFloatByField(java.lang.String field)
java.lang.ClassCastException
- If that field is not a Floatjava.lang.IllegalArgumentException
- - if field does not existbyte[] getBinaryByField(java.lang.String field)
java.lang.ClassCastException
- If that field is not a byte arrayjava.lang.IllegalArgumentException
- - if field does not existjava.util.List<java.lang.Object> getValues()
GlobalStreamId getSourceGlobalStreamId()
java.lang.String getSourceComponent()
int getSourceTask()
java.lang.String getSourceStreamId()
void resetValues()