Package org.apache.storm.tuple
Class TupleImpl
java.lang.Object
org.apache.storm.tuple.TupleImpl
- Direct Known Subclasses:
ClojureTuple
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionbooleanReturns true if this tuple contains the specified name of the field.booleanintfieldIndex(String field) Returns the position of the specified field in this tuple.longbyte[]getBinary(int i) Returns the byte array at position i in the tuple.byte[]getBinaryByField(String field) Gets the Byte array field with a specific name.getBoolean(int i) Returns the Boolean at position i in the tuple.getBooleanByField(String field) Gets the Boolean field with a specific name.getByte(int i) Returns the Byte at position i in the tuple.getByteByField(String field) Gets the Byte field with a specific name.Gets the topology context associated with the tuple.getDouble(int i) Returns the Double at position i in the tuple.getDoubleByField(String field) Gets the Double field with a specific name.Gets the names of the fields in this tuple.getFloat(int i) Returns the Float at position i in the tuple.getFloatByField(String field) Gets the Float field with a specific name.getInteger(int i) Returns the Integer at position i in the tuple.getIntegerByField(String field) Gets the Integer field with a specific name.getLong(int i) Returns the Long at position i in the tuple.getLongByField(String field) Gets the Long field with a specific name.Gets the message id that associated with this tuple.getShort(int i) Returns the Short at position i in the tuple.getShortByField(String field) Gets the Short field with a specific name.Gets the id of the component that created this tuple.Returns the global stream id (component + stream) of this tuple.Gets the id of the stream that this tuple was emitted to.intGets the id of the task that created this tuple.getString(int i) Returns the String at position i in the tuple.getStringByField(String field) Gets the String field with a specific name.getValue(int i) Gets the field at position i in the tuple.getValueByField(String field) Gets the field with a specific name.Gets all the values in this tuple.inthashCode()Returns a subset of the tuple based on the fields selector.voidsetExecuteSampleStartTime(long ms) voidsetProcessSampleStartTime(long ms) intsize()Returns the number of fields in this tuple.toString()voidupdateAckVal(long val)
-
Constructor Details
-
TupleImpl
-
TupleImpl
-
TupleImpl
public TupleImpl(GeneralTopologyContext context, List<Object> values, String srcComponent, int taskId, String streamId)
-
-
Method Details
-
getProcessSampleStartTime
-
setProcessSampleStartTime
public void setProcessSampleStartTime(long ms) -
getExecuteSampleStartTime
-
setExecuteSampleStartTime
public void setExecuteSampleStartTime(long ms) -
updateAckVal
public void updateAckVal(long val) -
getAckVal
public long getAckVal() -
size
public int size()Description copied from interface:ITupleReturns the number of fields in this tuple. -
fieldIndex
Description copied from interface:ITupleReturns the position of the specified field in this tuple.- Specified by:
fieldIndexin interfaceITuple
-
contains
Description copied from interface:ITupleReturns true if this tuple contains the specified name of the field. -
getValue
Description copied from interface:ITupleGets the field at position i in the tuple. Returns object since tuples are dynamically typed. -
getString
Description copied from interface:ITupleReturns the String at position i in the tuple. -
getInteger
Description copied from interface:ITupleReturns the Integer at position i in the tuple.- Specified by:
getIntegerin interfaceITuple
-
getLong
Description copied from interface:ITupleReturns the Long at position i in the tuple. -
getBoolean
Description copied from interface:ITupleReturns the Boolean at position i in the tuple.- Specified by:
getBooleanin interfaceITuple
-
getShort
Description copied from interface:ITupleReturns the Short at position i in the tuple. -
getByte
Description copied from interface:ITupleReturns the Byte at position i in the tuple. -
getDouble
Description copied from interface:ITupleReturns the Double at position i in the tuple. -
getFloat
Description copied from interface:ITupleReturns the Float at position i in the tuple. -
getBinary
public byte[] getBinary(int i) Description copied from interface:ITupleReturns the byte array at position i in the tuple. -
getValueByField
Description copied from interface:ITupleGets the field with a specific name. Returns object since tuples are dynamically typed.- Specified by:
getValueByFieldin interfaceITuple
-
getStringByField
Description copied from interface:ITupleGets the String field with a specific name.- Specified by:
getStringByFieldin interfaceITuple
-
getIntegerByField
Description copied from interface:ITupleGets the Integer field with a specific name.- Specified by:
getIntegerByFieldin interfaceITuple
-
getLongByField
Description copied from interface:ITupleGets the Long field with a specific name.- Specified by:
getLongByFieldin interfaceITuple
-
getBooleanByField
Description copied from interface:ITupleGets the Boolean field with a specific name.- Specified by:
getBooleanByFieldin interfaceITuple
-
getShortByField
Description copied from interface:ITupleGets the Short field with a specific name.- Specified by:
getShortByFieldin interfaceITuple
-
getByteByField
Description copied from interface:ITupleGets the Byte field with a specific name.- Specified by:
getByteByFieldin interfaceITuple
-
getDoubleByField
Description copied from interface:ITupleGets the Double field with a specific name.- Specified by:
getDoubleByFieldin interfaceITuple
-
getFloatByField
Description copied from interface:ITupleGets the Float field with a specific name.- Specified by:
getFloatByFieldin interfaceITuple
-
getBinaryByField
Description copied from interface:ITupleGets the Byte array field with a specific name.- Specified by:
getBinaryByFieldin interfaceITuple
-
getValues
Description copied from interface:ITupleGets all the values in this tuple. -
getFields
Description copied from interface:ITupleGets the names of the fields in this tuple. -
select
Description copied from interface:ITupleReturns a subset of the tuple based on the fields selector. -
getSourceGlobalStreamId
Description copied from interface:TupleReturns the global stream id (component + stream) of this tuple.- Specified by:
getSourceGlobalStreamIdin interfaceTuple
-
getSourceComponent
Description copied from interface:TupleGets the id of the component that created this tuple.- Specified by:
getSourceComponentin interfaceTuple
-
getSourceTask
public int getSourceTask()Description copied from interface:TupleGets the id of the task that created this tuple.- Specified by:
getSourceTaskin interfaceTuple
-
getSourceStreamId
Description copied from interface:TupleGets the id of the stream that this tuple was emitted to.- Specified by:
getSourceStreamIdin interfaceTuple
-
getMessageId
Description copied from interface:TupleGets the message id that associated with this tuple.- Specified by:
getMessageIdin interfaceTuple
-
getContext
Description copied from interface:TupleGets the topology context associated with the tuple.- Specified by:
getContextin interfaceTuple
-
toString
-
equals
-
hashCode
public int hashCode()
-