|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object AFn backtype.storm.utils.IndifferentAccessMap backtype.storm.tuple.TupleImpl
public class TupleImpl
Nested Class Summary |
---|
Nested classes/interfaces inherited from interface java.util.Map |
---|
java.util.Map.Entry<K,V> |
Field Summary |
---|
Fields inherited from class backtype.storm.utils.IndifferentAccessMap |
---|
_map |
Constructor Summary | |
---|---|
TupleImpl(GeneralTopologyContext context,
java.util.List<java.lang.Object> values,
int taskId,
java.lang.String streamId)
|
|
TupleImpl(GeneralTopologyContext context,
java.util.List<java.lang.Object> values,
int taskId,
java.lang.String streamId,
MessageId id)
|
Method Summary | |
---|---|
boolean |
contains(java.lang.String field)
Returns true if this tuple contains the specified name of the field. |
int |
count()
|
boolean |
equals(java.lang.Object other)
|
int |
fieldIndex(java.lang.String field)
Returns the position of the specified field in this tuple. |
long |
getAckVal()
|
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)
|
IPersistentMap |
getMap()
|
MessageId |
getMessageId()
Gets the message id that associated with this tuple. |
java.lang.Long |
getSampleStartTime()
|
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. |
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)
|
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. |
int |
hashCode()
|
IPersistentMap |
meta()
|
java.lang.Object |
nth(int i)
|
java.lang.Object |
nth(int i,
java.lang.Object notfound)
|
java.util.List<java.lang.Object> |
select(Fields selector)
Returns a subset of the tuple based on the fields selector. |
ISeq |
seq()
|
void |
setSampleStartTime(long ms)
|
int |
size()
Returns the number of fields in this tuple. |
java.lang.String |
toString()
|
void |
updateAckVal(long val)
|
java.lang.Object |
valAt(java.lang.Object o)
|
Methods inherited from class backtype.storm.utils.IndifferentAccessMap |
---|
assoc, assocEx, clear, cons, containsKey, containsValue, empty, entryAt, entrySet, equiv, get, invoke, invoke, isEmpty, iterator, keySet, put, putAll, remove, setMap, valAt, values, without |
Methods inherited from class java.lang.Object |
---|
clone, finalize, getClass, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public TupleImpl(GeneralTopologyContext context, java.util.List<java.lang.Object> values, int taskId, java.lang.String streamId, MessageId id)
public TupleImpl(GeneralTopologyContext context, java.util.List<java.lang.Object> values, int taskId, java.lang.String streamId)
Method Detail |
---|
public void setSampleStartTime(long ms)
public java.lang.Long getSampleStartTime()
public void updateAckVal(long val)
public long getAckVal()
public int size()
Tuple
size
in interface Tuple
size
in interface java.util.Map
size
in class IndifferentAccessMap
public int fieldIndex(java.lang.String field)
Tuple
fieldIndex
in interface Tuple
public boolean contains(java.lang.String field)
Tuple
contains
in interface Tuple
public java.lang.Object getValue(int i)
Tuple
getValue
in interface Tuple
public java.lang.String getString(int i)
Tuple
getString
in interface Tuple
public java.lang.Integer getInteger(int i)
Tuple
getInteger
in interface Tuple
public java.lang.Long getLong(int i)
Tuple
getLong
in interface Tuple
public java.lang.Boolean getBoolean(int i)
Tuple
getBoolean
in interface Tuple
public java.lang.Short getShort(int i)
Tuple
getShort
in interface Tuple
public java.lang.Byte getByte(int i)
Tuple
getByte
in interface Tuple
public java.lang.Double getDouble(int i)
Tuple
getDouble
in interface Tuple
public java.lang.Float getFloat(int i)
Tuple
getFloat
in interface Tuple
public byte[] getBinary(int i)
Tuple
getBinary
in interface Tuple
public java.lang.Object getValueByField(java.lang.String field)
getValueByField
in interface Tuple
public java.lang.String getStringByField(java.lang.String field)
getStringByField
in interface Tuple
public java.lang.Integer getIntegerByField(java.lang.String field)
getIntegerByField
in interface Tuple
public java.lang.Long getLongByField(java.lang.String field)
getLongByField
in interface Tuple
public java.lang.Boolean getBooleanByField(java.lang.String field)
getBooleanByField
in interface Tuple
public java.lang.Short getShortByField(java.lang.String field)
getShortByField
in interface Tuple
public java.lang.Byte getByteByField(java.lang.String field)
getByteByField
in interface Tuple
public java.lang.Double getDoubleByField(java.lang.String field)
getDoubleByField
in interface Tuple
public java.lang.Float getFloatByField(java.lang.String field)
getFloatByField
in interface Tuple
public byte[] getBinaryByField(java.lang.String field)
getBinaryByField
in interface Tuple
public java.util.List<java.lang.Object> getValues()
Tuple
getValues
in interface Tuple
public Fields getFields()
Tuple
getFields
in interface Tuple
public java.util.List<java.lang.Object> select(Fields selector)
Tuple
select
in interface Tuple
public GlobalStreamId getSourceGlobalStreamid()
Tuple
getSourceGlobalStreamid
in interface Tuple
public java.lang.String getSourceComponent()
Tuple
getSourceComponent
in interface Tuple
public int getSourceTask()
Tuple
getSourceTask
in interface Tuple
public java.lang.String getSourceStreamId()
Tuple
getSourceStreamId
in interface Tuple
public MessageId getMessageId()
Tuple
getMessageId
in interface Tuple
public java.lang.String toString()
public boolean equals(java.lang.Object other)
equals
in interface java.util.Map
public int hashCode()
hashCode
in interface java.util.Map
public java.lang.Object valAt(java.lang.Object o)
valAt
in class IndifferentAccessMap
public ISeq seq()
seq
in class IndifferentAccessMap
public java.lang.Object nth(int i)
public java.lang.Object nth(int i, java.lang.Object notfound)
public int count()
count
in class IndifferentAccessMap
public IPersistentMap meta()
public IPersistentMap getMap()
getMap
in class IndifferentAccessMap
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |