public class LightTuple extends Object implements org.apache.storm.tuple.Tuple
Modifier and Type | Method and Description |
---|---|
void |
ack()
Only after all anchors have acked will the tuple be acked to the originating spout.
|
void |
check()
Check if this tuple has been emitted at least once.
|
boolean |
contains(String field) |
boolean |
equals(Object other) |
void |
fail()
Once a tuple is failed, subsequent fail or acks are discarded.
|
int |
fieldIndex(String field) |
LightTuple |
getAnchor() |
Object |
getAttachement()
The attachement is an arbitrary object attached to that tuple.
|
byte[] |
getBinary(int i) |
byte[] |
getBinaryByField(String field) |
static LightTuple |
getBoltTuple(String streamId,
String sourceComponentId,
List<Object> values,
org.apache.storm.tuple.Fields fields,
LightTuple anchor)
Build a new bolt tuple.
|
Boolean |
getBoolean(int i) |
Boolean |
getBooleanByField(String field) |
Byte |
getByte(int i) |
Byte |
getByteByField(String field) |
org.apache.storm.task.GeneralTopologyContext |
getContext() |
Double |
getDouble(int i) |
Double |
getDoubleByField(String field) |
org.apache.storm.tuple.Fields |
getFields() |
Float |
getFloat(int i) |
Float |
getFloatByField(String field) |
Integer |
getInteger(int i) |
Integer |
getIntegerByField(String field) |
Long |
getLong(int i) |
Long |
getLongByField(String field) |
org.apache.storm.tuple.MessageId |
getMessageId() |
long |
getRefCount() |
Short |
getShort(int i) |
Short |
getShortByField(String field) |
String |
getSourceComponent() |
org.apache.storm.generated.GlobalStreamId |
getSourceGlobalStreamId() |
String |
getSourceStreamId() |
int |
getSourceTask() |
static LightTuple |
getSpoutTuple(String streamId,
String sourceComponentId,
List<Object> values,
org.apache.storm.tuple.Fields fields,
Object messageId)
Build a new spout tuple.
|
String |
getString(int i) |
String |
getStringByField(String field) |
static LightTuple |
getTickTuple() |
long |
getUuid() |
Object |
getValue(int i) |
Object |
getValueByField(String field) |
List<Object> |
getValues() |
int |
hashCode() |
LightTuple |
inc() |
boolean |
isSpoutTuple()
This method is thread-safe.
|
List<Object> |
select(org.apache.storm.tuple.Fields selector) |
LightTuple |
setAcker(LightAcker acker)
Only a spout is interested to know when this tuple ack or fail.
|
int |
size() |
String |
toString() |
public static LightTuple getSpoutTuple(String streamId, String sourceComponentId, List<Object> values, org.apache.storm.tuple.Fields fields, Object messageId)
streamId
- streamIdsourceComponentId
- sourceComponentIdvalues
- valuesfields
- fieldsmessageId
- messageIdpublic static LightTuple getBoltTuple(String streamId, String sourceComponentId, List<Object> values, org.apache.storm.tuple.Fields fields, LightTuple anchor)
streamId
- streamIdsourceComponentId
- sourceComponentIdvalues
- valuesfields
- fieldsanchor
- anchorpublic LightTuple setAcker(LightAcker acker)
acker
- a LightSpoutpublic LightTuple getAnchor()
public long getRefCount()
public static LightTuple getTickTuple()
public long getUuid()
public Object getAttachement()
public boolean isSpoutTuple()
public void fail()
public void check()
public void ack()
public LightTuple inc()
public int size()
size
in interface org.apache.storm.tuple.ITuple
public int fieldIndex(String field)
fieldIndex
in interface org.apache.storm.tuple.ITuple
public boolean contains(String field)
contains
in interface org.apache.storm.tuple.ITuple
public Object getValue(int i)
getValue
in interface org.apache.storm.tuple.ITuple
public String getString(int i)
getString
in interface org.apache.storm.tuple.ITuple
public Integer getInteger(int i)
getInteger
in interface org.apache.storm.tuple.ITuple
public Long getLong(int i)
getLong
in interface org.apache.storm.tuple.ITuple
public Boolean getBoolean(int i)
getBoolean
in interface org.apache.storm.tuple.ITuple
public Short getShort(int i)
getShort
in interface org.apache.storm.tuple.ITuple
public Byte getByte(int i)
getByte
in interface org.apache.storm.tuple.ITuple
public Double getDouble(int i)
getDouble
in interface org.apache.storm.tuple.ITuple
public Float getFloat(int i)
getFloat
in interface org.apache.storm.tuple.ITuple
public byte[] getBinary(int i)
getBinary
in interface org.apache.storm.tuple.ITuple
public Object getValueByField(String field)
getValueByField
in interface org.apache.storm.tuple.ITuple
public String getStringByField(String field)
getStringByField
in interface org.apache.storm.tuple.ITuple
public Integer getIntegerByField(String field)
getIntegerByField
in interface org.apache.storm.tuple.ITuple
public Long getLongByField(String field)
getLongByField
in interface org.apache.storm.tuple.ITuple
public Boolean getBooleanByField(String field)
getBooleanByField
in interface org.apache.storm.tuple.ITuple
public Short getShortByField(String field)
getShortByField
in interface org.apache.storm.tuple.ITuple
public Byte getByteByField(String field)
getByteByField
in interface org.apache.storm.tuple.ITuple
public Double getDoubleByField(String field)
getDoubleByField
in interface org.apache.storm.tuple.ITuple
public Float getFloatByField(String field)
getFloatByField
in interface org.apache.storm.tuple.ITuple
public byte[] getBinaryByField(String field)
getBinaryByField
in interface org.apache.storm.tuple.ITuple
public List<Object> getValues()
getValues
in interface org.apache.storm.tuple.ITuple
public org.apache.storm.tuple.Fields getFields()
getFields
in interface org.apache.storm.tuple.ITuple
public List<Object> select(org.apache.storm.tuple.Fields selector)
select
in interface org.apache.storm.tuple.ITuple
public org.apache.storm.generated.GlobalStreamId getSourceGlobalStreamId()
getSourceGlobalStreamId
in interface org.apache.storm.tuple.Tuple
public String getSourceComponent()
getSourceComponent
in interface org.apache.storm.tuple.Tuple
public int getSourceTask()
getSourceTask
in interface org.apache.storm.tuple.Tuple
public String getSourceStreamId()
getSourceStreamId
in interface org.apache.storm.tuple.Tuple
public org.apache.storm.tuple.MessageId getMessageId()
getMessageId
in interface org.apache.storm.tuple.Tuple
public org.apache.storm.task.GeneralTopologyContext getContext()
getContext
in interface org.apache.storm.tuple.Tuple
Copyright © 2023. All rights reserved.