org.apache.storm.tuple

Class TupleImpl

java.lang.Object

clojure.lang.AFn

org.apache.storm.utils.IndifferentAccessMap

org.apache.storm.tuple.TupleImpl

All Implemented Interfaces:

clojure.lang.Associative, clojure.lang.Counted, clojure.lang.IFn, clojure.lang.ILookup, clojure.lang.IMeta, clojure.lang.Indexed, clojure.lang.IPersistentCollection, clojure.lang.IPersistentMap, clojure.lang.Seqable, Iterable, Runnable, Callable, Map, ITuple, Tuple

public class TupleImpl
extends IndifferentAccessMap
implements clojure.lang.Seqable, clojure.lang.Indexed, clojure.lang.IMeta, Tuple

Nested Class Summary

Nested classes/interfaces inherited from interface java.util.Map

Map.Entry<K,V>

Nested classes/interfaces inherited from interface clojure.lang.IFn

clojure.lang.IFn.D, clojure.lang.IFn.DD, clojure.lang.IFn.DDD, clojure.lang.IFn.DDDD, clojure.lang.IFn.DDDDD, clojure.lang.IFn.DDDDL, clojure.lang.IFn.DDDDO, clojure.lang.IFn.DDDL, clojure.lang.IFn.DDDLD, clojure.lang.IFn.DDDLL, clojure.lang.IFn.DDDLO, clojure.lang.IFn.DDDO, clojure.lang.IFn.DDDOD, clojure.lang.IFn.DDDOL, clojure.lang.IFn.DDDOO, clojure.lang.IFn.DDL, clojure.lang.IFn.DDLD, clojure.lang.IFn.DDLDD, clojure.lang.IFn.DDLDL, clojure.lang.IFn.DDLDO, clojure.lang.IFn.DDLL, clojure.lang.IFn.DDLLD, clojure.lang.IFn.DDLLL, clojure.lang.IFn.DDLLO, clojure.lang.IFn.DDLO, clojure.lang.IFn.DDLOD, clojure.lang.IFn.DDLOL, clojure.lang.IFn.DDLOO, clojure.lang.IFn.DDO, clojure.lang.IFn.DDOD, clojure.lang.IFn.DDODD, clojure.lang.IFn.DDODL, clojure.lang.IFn.DDODO, clojure.lang.IFn.DDOL, clojure.lang.IFn.DDOLD, clojure.lang.IFn.DDOLL, clojure.lang.IFn.DDOLO, clojure.lang.IFn.DDOO, clojure.lang.IFn.DDOOD, clojure.lang.IFn.DDOOL, clojure.lang.IFn.DDOOO, clojure.lang.IFn.DL, clojure.lang.IFn.DLD, clojure.lang.IFn.DLDD, clojure.lang.IFn.DLDDD, clojure.lang.IFn.DLDDL, clojure.lang.IFn.DLDDO, clojure.lang.IFn.DLDL, clojure.lang.IFn.DLDLD, clojure.lang.IFn.DLDLL, clojure.lang.IFn.DLDLO, clojure.lang.IFn.DLDO, clojure.lang.IFn.DLDOD, clojure.lang.IFn.DLDOL, clojure.lang.IFn.DLDOO, clojure.lang.IFn.DLL, clojure.lang.IFn.DLLD, clojure.lang.IFn.DLLDD, clojure.lang.IFn.DLLDL, clojure.lang.IFn.DLLDO, clojure.lang.IFn.DLLL, clojure.lang.IFn.DLLLD, clojure.lang.IFn.DLLLL, clojure.lang.IFn.DLLLO, clojure.lang.IFn.DLLO, clojure.lang.IFn.DLLOD, clojure.lang.IFn.DLLOL, clojure.lang.IFn.DLLOO, clojure.lang.IFn.DLO, clojure.lang.IFn.DLOD, clojure.lang.IFn.DLODD, clojure.lang.IFn.DLODL, clojure.lang.IFn.DLODO, clojure.lang.IFn.DLOL, clojure.lang.IFn.DLOLD, clojure.lang.IFn.DLOLL, clojure.lang.IFn.DLOLO, clojure.lang.IFn.DLOO, clojure.lang.IFn.DLOOD, clojure.lang.IFn.DLOOL, clojure.lang.IFn.DLOOO, clojure.lang.IFn.DO, clojure.lang.IFn.DOD, clojure.lang.IFn.DODD, clojure.lang.IFn.DODDD, clojure.lang.IFn.DODDL, clojure.lang.IFn.DODDO, clojure.lang.IFn.DODL, clojure.lang.IFn.DODLD, clojure.lang.IFn.DODLL, clojure.lang.IFn.DODLO, clojure.lang.IFn.DODO, clojure.lang.IFn.DODOD, clojure.lang.IFn.DODOL, clojure.lang.IFn.DODOO, clojure.lang.IFn.DOL, clojure.lang.IFn.DOLD, clojure.lang.IFn.DOLDD, clojure.lang.IFn.DOLDL, clojure.lang.IFn.DOLDO, clojure.lang.IFn.DOLL, clojure.lang.IFn.DOLLD, clojure.lang.IFn.DOLLL, clojure.lang.IFn.DOLLO, clojure.lang.IFn.DOLO, clojure.lang.IFn.DOLOD, clojure.lang.IFn.DOLOL, clojure.lang.IFn.DOLOO, clojure.lang.IFn.DOO, clojure.lang.IFn.DOOD, clojure.lang.IFn.DOODD, clojure.lang.IFn.DOODL, clojure.lang.IFn.DOODO, clojure.lang.IFn.DOOL, clojure.lang.IFn.DOOLD, clojure.lang.IFn.DOOLL, clojure.lang.IFn.DOOLO, clojure.lang.IFn.DOOO, clojure.lang.IFn.DOOOD, clojure.lang.IFn.DOOOL, clojure.lang.IFn.DOOOO, clojure.lang.IFn.L, clojure.lang.IFn.LD, clojure.lang.IFn.LDD, clojure.lang.IFn.LDDD, clojure.lang.IFn.LDDDD, clojure.lang.IFn.LDDDL, clojure.lang.IFn.LDDDO, clojure.lang.IFn.LDDL, clojure.lang.IFn.LDDLD, clojure.lang.IFn.LDDLL, clojure.lang.IFn.LDDLO, clojure.lang.IFn.LDDO, clojure.lang.IFn.LDDOD, clojure.lang.IFn.LDDOL, clojure.lang.IFn.LDDOO, clojure.lang.IFn.LDL, clojure.lang.IFn.LDLD, clojure.lang.IFn.LDLDD, clojure.lang.IFn.LDLDL, clojure.lang.IFn.LDLDO, clojure.lang.IFn.LDLL, clojure.lang.IFn.LDLLD, clojure.lang.IFn.LDLLL, clojure.lang.IFn.LDLLO, clojure.lang.IFn.LDLO, clojure.lang.IFn.LDLOD, clojure.lang.IFn.LDLOL, clojure.lang.IFn.LDLOO, clojure.lang.IFn.LDO, clojure.lang.IFn.LDOD, clojure.lang.IFn.LDODD, clojure.lang.IFn.LDODL, clojure.lang.IFn.LDODO, clojure.lang.IFn.LDOL, clojure.lang.IFn.LDOLD, clojure.lang.IFn.LDOLL, clojure.lang.IFn.LDOLO, clojure.lang.IFn.LDOO, clojure.lang.IFn.LDOOD, clojure.lang.IFn.LDOOL, clojure.lang.IFn.LDOOO, clojure.lang.IFn.LL, clojure.lang.IFn.LLD, clojure.lang.IFn.LLDD, clojure.lang.IFn.LLDDD, clojure.lang.IFn.LLDDL, clojure.lang.IFn.LLDDO, clojure.lang.IFn.LLDL, clojure.lang.IFn.LLDLD, clojure.lang.IFn.LLDLL, clojure.lang.IFn.LLDLO, clojure.lang.IFn.LLDO, clojure.lang.IFn.LLDOD, clojure.lang.IFn.LLDOL, clojure.lang.IFn.LLDOO, clojure.lang.IFn.LLL, clojure.lang.IFn.LLLD, clojure.lang.IFn.LLLDD, clojure.lang.IFn.LLLDL, clojure.lang.IFn.LLLDO, clojure.lang.IFn.LLLL, clojure.lang.IFn.LLLLD, clojure.lang.IFn.LLLLL, clojure.lang.IFn.LLLLO, clojure.lang.IFn.LLLO, clojure.lang.IFn.LLLOD, clojure.lang.IFn.LLLOL, clojure.lang.IFn.LLLOO, clojure.lang.IFn.LLO, clojure.lang.IFn.LLOD, clojure.lang.IFn.LLODD, clojure.lang.IFn.LLODL, clojure.lang.IFn.LLODO, clojure.lang.IFn.LLOL, clojure.lang.IFn.LLOLD, clojure.lang.IFn.LLOLL, clojure.lang.IFn.LLOLO, clojure.lang.IFn.LLOO, clojure.lang.IFn.LLOOD, clojure.lang.IFn.LLOOL, clojure.lang.IFn.LLOOO, clojure.lang.IFn.LO, clojure.lang.IFn.LOD, clojure.lang.IFn.LODD, clojure.lang.IFn.LODDD, clojure.lang.IFn.LODDL, clojure.lang.IFn.LODDO, clojure.lang.IFn.LODL, clojure.lang.IFn.LODLD, clojure.lang.IFn.LODLL, clojure.lang.IFn.LODLO, clojure.lang.IFn.LODO, clojure.lang.IFn.LODOD, clojure.lang.IFn.LODOL, clojure.lang.IFn.LODOO, clojure.lang.IFn.LOL, clojure.lang.IFn.LOLD, clojure.lang.IFn.LOLDD, clojure.lang.IFn.LOLDL, clojure.lang.IFn.LOLDO, clojure.lang.IFn.LOLL, clojure.lang.IFn.LOLLD, clojure.lang.IFn.LOLLL, clojure.lang.IFn.LOLLO, clojure.lang.IFn.LOLO, clojure.lang.IFn.LOLOD, clojure.lang.IFn.LOLOL, clojure.lang.IFn.LOLOO, clojure.lang.IFn.LOO, clojure.lang.IFn.LOOD, clojure.lang.IFn.LOODD, clojure.lang.IFn.LOODL, clojure.lang.IFn.LOODO, clojure.lang.IFn.LOOL, clojure.lang.IFn.LOOLD, clojure.lang.IFn.LOOLL, clojure.lang.IFn.LOOLO, clojure.lang.IFn.LOOO, clojure.lang.IFn.LOOOD, clojure.lang.IFn.LOOOL, clojure.lang.IFn.LOOOO, clojure.lang.IFn.OD, clojure.lang.IFn.ODD, clojure.lang.IFn.ODDD, clojure.lang.IFn.ODDDD, clojure.lang.IFn.ODDDL, clojure.lang.IFn.ODDDO, clojure.lang.IFn.ODDL, clojure.lang.IFn.ODDLD, clojure.lang.IFn.ODDLL, clojure.lang.IFn.ODDLO, clojure.lang.IFn.ODDO, clojure.lang.IFn.ODDOD, clojure.lang.IFn.ODDOL, clojure.lang.IFn.ODDOO, clojure.lang.IFn.ODL, clojure.lang.IFn.ODLD, clojure.lang.IFn.ODLDD, clojure.lang.IFn.ODLDL, clojure.lang.IFn.ODLDO, clojure.lang.IFn.ODLL, clojure.lang.IFn.ODLLD, clojure.lang.IFn.ODLLL, clojure.lang.IFn.ODLLO, clojure.lang.IFn.ODLO, clojure.lang.IFn.ODLOD, clojure.lang.IFn.ODLOL, clojure.lang.IFn.ODLOO, clojure.lang.IFn.ODO, clojure.lang.IFn.ODOD, clojure.lang.IFn.ODODD, clojure.lang.IFn.ODODL, clojure.lang.IFn.ODODO, clojure.lang.IFn.ODOL, clojure.lang.IFn.ODOLD, clojure.lang.IFn.ODOLL, clojure.lang.IFn.ODOLO, clojure.lang.IFn.ODOO, clojure.lang.IFn.ODOOD, clojure.lang.IFn.ODOOL, clojure.lang.IFn.ODOOO, clojure.lang.IFn.OL, clojure.lang.IFn.OLD, clojure.lang.IFn.OLDD, clojure.lang.IFn.OLDDD, clojure.lang.IFn.OLDDL, clojure.lang.IFn.OLDDO, clojure.lang.IFn.OLDL, clojure.lang.IFn.OLDLD, clojure.lang.IFn.OLDLL, clojure.lang.IFn.OLDLO, clojure.lang.IFn.OLDO, clojure.lang.IFn.OLDOD, clojure.lang.IFn.OLDOL, clojure.lang.IFn.OLDOO, clojure.lang.IFn.OLL, clojure.lang.IFn.OLLD, clojure.lang.IFn.OLLDD, clojure.lang.IFn.OLLDL, clojure.lang.IFn.OLLDO, clojure.lang.IFn.OLLL, clojure.lang.IFn.OLLLD, clojure.lang.IFn.OLLLL, clojure.lang.IFn.OLLLO, clojure.lang.IFn.OLLO, clojure.lang.IFn.OLLOD, clojure.lang.IFn.OLLOL, clojure.lang.IFn.OLLOO, clojure.lang.IFn.OLO, clojure.lang.IFn.OLOD, clojure.lang.IFn.OLODD, clojure.lang.IFn.OLODL, clojure.lang.IFn.OLODO, clojure.lang.IFn.OLOL, clojure.lang.IFn.OLOLD, clojure.lang.IFn.OLOLL, clojure.lang.IFn.OLOLO, clojure.lang.IFn.OLOO, clojure.lang.IFn.OLOOD, clojure.lang.IFn.OLOOL, clojure.lang.IFn.OLOOO, clojure.lang.IFn.OOD, clojure.lang.IFn.OODD, clojure.lang.IFn.OODDD, clojure.lang.IFn.OODDL, clojure.lang.IFn.OODDO, clojure.lang.IFn.OODL, clojure.lang.IFn.OODLD, clojure.lang.IFn.OODLL, clojure.lang.IFn.OODLO, clojure.lang.IFn.OODO, clojure.lang.IFn.OODOD, clojure.lang.IFn.OODOL, clojure.lang.IFn.OODOO, clojure.lang.IFn.OOL, clojure.lang.IFn.OOLD, clojure.lang.IFn.OOLDD, clojure.lang.IFn.OOLDL, clojure.lang.IFn.OOLDO, clojure.lang.IFn.OOLL, clojure.lang.IFn.OOLLD, clojure.lang.IFn.OOLLL, clojure.lang.IFn.OOLLO, clojure.lang.IFn.OOLO, clojure.lang.IFn.OOLOD, clojure.lang.IFn.OOLOL, clojure.lang.IFn.OOLOO, clojure.lang.IFn.OOOD, clojure.lang.IFn.OOODD, clojure.lang.IFn.OOODL, clojure.lang.IFn.OOODO, clojure.lang.IFn.OOOL, clojure.lang.IFn.OOOLD, clojure.lang.IFn.OOOLL, clojure.lang.IFn.OOOLO, clojure.lang.IFn.OOOOD, clojure.lang.IFn.OOOOL

Field Summary

Fields inherited from class org.apache.storm.utils.IndifferentAccessMap

_map

Constructor Summary

Constructors

Constructor and Description
TupleImpl(GeneralTopologyContext context, List<Object> values, int taskId, String streamId)
TupleImpl(GeneralTopologyContext context, List<Object> values, int taskId, String streamId, MessageId id)

Method Summary

Modifier and Type	Method and Description
boolean	contains(String field) Returns true if this tuple contains the specified name of the field.
int	count()
boolean	equals(Object other)
int	fieldIndex(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(String field) Gets the Byte array field with a specific name.
Boolean	getBoolean(int i) Returns the Boolean at position i in the tuple.
Boolean	getBooleanByField(String field) Gets the Boolean field with a specific name.
Byte	getByte(int i) Returns the Byte at position i in the tuple.
Byte	getByteByField(String field) Gets the Byte field with a specific name.
Double	getDouble(int i) Returns the Double at position i in the tuple.
Double	getDoubleByField(String field) Gets the Double field with a specific name.
Long	getExecuteSampleStartTime()
Fields	getFields() Gets the names of the fields in this tuple.
Float	getFloat(int i) Returns the Float at position i in the tuple.
Float	getFloatByField(String field) Gets the Float field with a specific name.
Integer	getInteger(int i) Returns the Integer at position i in the tuple.
Integer	getIntegerByField(String field) Gets the Integer field with a specific name.
Long	getLong(int i) Returns the Long at position i in the tuple.
Long	getLongByField(String field) Gets the Long field with a specific name.
clojure.lang.IPersistentMap	getMap()
MessageId	getMessageId() Gets the message id that associated with this tuple.
Long	getProcessSampleStartTime()
Short	getShort(int i) Returns the Short at position i in the tuple.
Short	getShortByField(String field) Gets the Short field with a specific name.
String	getSourceComponent() Gets the id of the component that created this tuple.
GlobalStreamId	getSourceGlobalStreamid() Deprecated.
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.
String	getString(int i) Returns the String at position i in the tuple.
String	getStringByField(String field) Gets the String field with a specific name.
Object	getValue(int i) Gets the field at position i in the tuple.
Object	getValueByField(String field) Gets the field with a specific name.
List<Object>	getValues() Gets all the values in this tuple.
int	hashCode()
clojure.lang.IPersistentMap	meta()
Object	nth(int i)
Object	nth(int i, Object notfound)
List<Object>	select(Fields selector) Returns a subset of the tuple based on the fields selector.
clojure.lang.ISeq	seq()
void	setExecuteSampleStartTime(long ms)
void	setProcessSampleStartTime(long ms)
int	size() Returns the number of fields in this tuple.
String	toString()
void	updateAckVal(long val)
Object	valAt(Object o)

Methods inherited from class org.apache.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 clojure.lang.AFn

applyTo, applyToHelper, call, invoke, invoke, invoke, invoke, invoke, invoke, invoke, invoke, invoke, invoke, invoke, invoke, invoke, invoke, invoke, invoke, invoke, invoke, invoke, invoke, run, throwArity

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Methods inherited from interface java.util.Map

compute, computeIfAbsent, computeIfPresent, forEach, getOrDefault, merge, putIfAbsent, remove, replace, replace, replaceAll

Constructor Detail

TupleImpl

public TupleImpl(GeneralTopologyContext context,
                 List<Object> values,
                 int taskId,
                 String streamId,
                 MessageId id)

TupleImpl

public TupleImpl(GeneralTopologyContext context,
                 List<Object> values,
                 int taskId,
                 String streamId)

Method Detail

setProcessSampleStartTime

public void setProcessSampleStartTime(long ms)

getProcessSampleStartTime

public Long getProcessSampleStartTime()

setExecuteSampleStartTime

public void setExecuteSampleStartTime(long ms)

getExecuteSampleStartTime

public Long getExecuteSampleStartTime()

updateAckVal

public void updateAckVal(long val)

getAckVal

public long getAckVal()

size

public int size()

Description copied from interface: ITuple

Returns the number of fields in this tuple.

Specified by:

size in interface Map

Specified by:

size in interface ITuple

Overrides:

size in class IndifferentAccessMap

fieldIndex

public int fieldIndex(String field)

Description copied from interface: ITuple

Returns the position of the specified field in this tuple.

Specified by:

fieldIndex in interface ITuple

contains

public boolean contains(String field)

Description copied from interface: ITuple

Returns true if this tuple contains the specified name of the field.

Specified by:

contains in interface ITuple

getValue

public Object getValue(int i)

Description copied from interface: ITuple

Gets the field at position i in the tuple. Returns object since tuples are dynamically typed.

Specified by:

getValue in interface ITuple

getString

public String getString(int i)

Description copied from interface: ITuple

Returns the String at position i in the tuple.

Specified by:

getString in interface ITuple

getInteger

public Integer getInteger(int i)

Description copied from interface: ITuple

Returns the Integer at position i in the tuple.

Specified by:

getInteger in interface ITuple

getLong

public Long getLong(int i)

Description copied from interface: ITuple

Returns the Long at position i in the tuple.

Specified by:

getLong in interface ITuple

getBoolean

public Boolean getBoolean(int i)

Description copied from interface: ITuple

Returns the Boolean at position i in the tuple.

Specified by:

getBoolean in interface ITuple

getShort

public Short getShort(int i)

Description copied from interface: ITuple

Returns the Short at position i in the tuple.

Specified by:

getShort in interface ITuple

getByte

public Byte getByte(int i)

Description copied from interface: ITuple

Returns the Byte at position i in the tuple.

Specified by:

getByte in interface ITuple

getDouble

public Double getDouble(int i)

Description copied from interface: ITuple

Returns the Double at position i in the tuple.

Specified by:

getDouble in interface ITuple

getFloat

public Float getFloat(int i)

Description copied from interface: ITuple

Returns the Float at position i in the tuple.

Specified by:

getFloat in interface ITuple

getBinary

public byte[] getBinary(int i)

Description copied from interface: ITuple

Returns the byte array at position i in the tuple.

Specified by:

getBinary in interface ITuple

getValueByField

public Object getValueByField(String field)

Description copied from interface: ITuple

Gets the field with a specific name. Returns object since tuples are dynamically typed.

Specified by:

getValueByField in interface ITuple

getStringByField

public String getStringByField(String field)

Description copied from interface: ITuple

Gets the String field with a specific name.

Specified by:

getStringByField in interface ITuple

getIntegerByField

public Integer getIntegerByField(String field)

Description copied from interface: ITuple

Gets the Integer field with a specific name.

Specified by:

getIntegerByField in interface ITuple

getLongByField

public Long getLongByField(String field)

Description copied from interface: ITuple

Gets the Long field with a specific name.

Specified by:

getLongByField in interface ITuple

getBooleanByField

public Boolean getBooleanByField(String field)

Description copied from interface: ITuple

Gets the Boolean field with a specific name.

Specified by:

getBooleanByField in interface ITuple

getShortByField

public Short getShortByField(String field)

Description copied from interface: ITuple

Gets the Short field with a specific name.

Specified by:

getShortByField in interface ITuple

getByteByField

public Byte getByteByField(String field)

Description copied from interface: ITuple

Gets the Byte field with a specific name.

Specified by:

getByteByField in interface ITuple

getDoubleByField

public Double getDoubleByField(String field)

Description copied from interface: ITuple

Gets the Double field with a specific name.

Specified by:

getDoubleByField in interface ITuple

getFloatByField

public Float getFloatByField(String field)

Description copied from interface: ITuple

Gets the Float field with a specific name.

Specified by:

getFloatByField in interface ITuple

getBinaryByField

public byte[] getBinaryByField(String field)

Description copied from interface: ITuple

Gets the Byte array field with a specific name.

Specified by:

getBinaryByField in interface ITuple

getValues

public List<Object> getValues()

Description copied from interface: ITuple

Gets all the values in this tuple.

Specified by:

getValues in interface ITuple

getFields

public Fields getFields()

Description copied from interface: ITuple

Gets the names of the fields in this tuple.

Specified by:

getFields in interface ITuple

select

public List<Object> select(Fields selector)

Description copied from interface: ITuple

Returns a subset of the tuple based on the fields selector.

Specified by:

select in interface ITuple

getSourceGlobalStreamid

@Deprecated
public GlobalStreamId getSourceGlobalStreamid()

Deprecated.

Description copied from interface: Tuple

Returns the global stream id (component + stream) of this tuple.

Specified by:

getSourceGlobalStreamid in interface Tuple

getSourceGlobalStreamId

public GlobalStreamId getSourceGlobalStreamId()

Description copied from interface: Tuple

Returns the global stream id (component + stream) of this tuple.

Specified by:

getSourceGlobalStreamId in interface Tuple

getSourceComponent

public String getSourceComponent()

Description copied from interface: Tuple

Gets the id of the component that created this tuple.

Specified by:

getSourceComponent in interface Tuple

getSourceTask

public int getSourceTask()

Description copied from interface: Tuple

Gets the id of the task that created this tuple.

Specified by:

getSourceTask in interface Tuple

getSourceStreamId

public String getSourceStreamId()

Description copied from interface: Tuple

Gets the id of the stream that this tuple was emitted to.

Specified by:

getSourceStreamId in interface Tuple

getMessageId

public MessageId getMessageId()

Description copied from interface: Tuple

Gets the message id that associated with this tuple.

Specified by:

getMessageId in interface Tuple

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object other)

Specified by:

equals in interface Map

Overrides:

equals in class Object

hashCode

public int hashCode()

Specified by:

hashCode in interface Map

Overrides:

hashCode in class Object

valAt

public Object valAt(Object o)

Specified by:

valAt in interface clojure.lang.ILookup

Overrides:

valAt in class IndifferentAccessMap

seq

public clojure.lang.ISeq seq()

Specified by:

seq in interface clojure.lang.Seqable

Overrides:

seq in class IndifferentAccessMap

nth

public Object nth(int i)

Specified by:

nth in interface clojure.lang.Indexed

nth

public Object nth(int i,
                  Object notfound)

Specified by:

nth in interface clojure.lang.Indexed

count

public int count()

Specified by:

count in interface clojure.lang.Counted

Specified by:

count in interface clojure.lang.IPersistentCollection

Overrides:

count in class IndifferentAccessMap

meta

public clojure.lang.IPersistentMap meta()

Specified by:

meta in interface clojure.lang.IMeta

getMap

public clojure.lang.IPersistentMap getMap()

Overrides:

getMap in class IndifferentAccessMap