org.apache.flink.storm.wrappers

Class StormTuple<IN>

java.lang.Object

org.apache.flink.storm.wrappers.StormTuple<IN>

All Implemented Interfaces:

backtype.storm.tuple.ITuple, backtype.storm.tuple.Tuple

public class StormTuple<IN>
extends Object
implements backtype.storm.tuple.Tuple

StormTuple converts a Flink tuple of type IN into a Storm tuple.

Constructor Summary

Constructors

Constructor and Description
StormTuple(IN flinkTuple, backtype.storm.tuple.Fields schema, int producerTaskId, String producerStreamId, String producerComponentId, backtype.storm.tuple.MessageId messageId) Create a new Storm tuple from the given Flink tuple.

Method Summary

Modifier and Type	Method and Description
boolean	contains(String field)
boolean	equals(Object obj)
int	fieldIndex(String field)
byte[]	getBinary(int i)
byte[]	getBinaryByField(String field)
Boolean	getBoolean(int i)
Boolean	getBooleanByField(String field)
Byte	getByte(int i)
Byte	getByteByField(String field)
Double	getDouble(int i)
Double	getDoubleByField(String field)
backtype.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)
backtype.storm.tuple.MessageId	getMessageId()
Short	getShort(int i)
Short	getShortByField(String field)
String	getSourceComponent()
backtype.storm.generated.GlobalStreamId	getSourceGlobalStreamid()
String	getSourceStreamId()
int	getSourceTask()
String	getString(int i)
String	getStringByField(String field)
Object	getValue(int i)
Object	getValueByField(String field)
<T> T	getValueByName(String field)
List<Object>	getValues()
int	hashCode()
List<Object>	select(backtype.storm.tuple.Fields selector)
int	size()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

StormTuple

public StormTuple(IN flinkTuple,
                  backtype.storm.tuple.Fields schema,
                  int producerTaskId,
                  String producerStreamId,
                  String producerComponentId,
                  backtype.storm.tuple.MessageId messageId)

Create a new Storm tuple from the given Flink tuple.

Parameters:

flinkTuple - The Flink tuple to be converted.

schema - The schema (ie, ordered field names) of the tuple.

producerTaskId - The task ID of the producer (a valid, ie, non-negative ID, implicates the truncation of the last attribute of flinkTuple).

producerStreamId - The input stream ID from which this tuple was received.

producerComponentId - The component ID of the producer.

messageId - The message ID of this tuple.

Method Detail

size

public int size()

Specified by:

size in interface backtype.storm.tuple.ITuple

contains

public boolean contains(String field)

Specified by:

contains in interface backtype.storm.tuple.ITuple

getFields

public backtype.storm.tuple.Fields getFields()

Specified by:

getFields in interface backtype.storm.tuple.ITuple

fieldIndex

public int fieldIndex(String field)

Specified by:

fieldIndex in interface backtype.storm.tuple.ITuple

select

public List<Object> select(backtype.storm.tuple.Fields selector)

Specified by:

select in interface backtype.storm.tuple.ITuple

getValue

public Object getValue(int i)

Specified by:

getValue in interface backtype.storm.tuple.ITuple

getString

public String getString(int i)

Specified by:

getString in interface backtype.storm.tuple.ITuple

getInteger

public Integer getInteger(int i)

Specified by:

getInteger in interface backtype.storm.tuple.ITuple

getLong

public Long getLong(int i)

Specified by:

getLong in interface backtype.storm.tuple.ITuple

getBoolean

public Boolean getBoolean(int i)

Specified by:

getBoolean in interface backtype.storm.tuple.ITuple

getShort

public Short getShort(int i)

Specified by:

getShort in interface backtype.storm.tuple.ITuple

getByte

public Byte getByte(int i)

Specified by:

getByte in interface backtype.storm.tuple.ITuple

getDouble

public Double getDouble(int i)

Specified by:

getDouble in interface backtype.storm.tuple.ITuple

getFloat

public Float getFloat(int i)

Specified by:

getFloat in interface backtype.storm.tuple.ITuple

getBinary

public byte[] getBinary(int i)

Specified by:

getBinary in interface backtype.storm.tuple.ITuple

getValueByName

public <T> T getValueByName(String field)

getValueByField

public Object getValueByField(String field)

Specified by:

getValueByField in interface backtype.storm.tuple.ITuple

getStringByField

public String getStringByField(String field)

Specified by:

getStringByField in interface backtype.storm.tuple.ITuple

getIntegerByField

public Integer getIntegerByField(String field)

Specified by:

getIntegerByField in interface backtype.storm.tuple.ITuple

getLongByField

public Long getLongByField(String field)

Specified by:

getLongByField in interface backtype.storm.tuple.ITuple

getBooleanByField

public Boolean getBooleanByField(String field)

Specified by:

getBooleanByField in interface backtype.storm.tuple.ITuple

getShortByField

public Short getShortByField(String field)

Specified by:

getShortByField in interface backtype.storm.tuple.ITuple

getByteByField

public Byte getByteByField(String field)

Specified by:

getByteByField in interface backtype.storm.tuple.ITuple

getDoubleByField

public Double getDoubleByField(String field)

Specified by:

getDoubleByField in interface backtype.storm.tuple.ITuple

getFloatByField

public Float getFloatByField(String field)

Specified by:

getFloatByField in interface backtype.storm.tuple.ITuple

getBinaryByField

public byte[] getBinaryByField(String field)

Specified by:

getBinaryByField in interface backtype.storm.tuple.ITuple

getValues

public List<Object> getValues()

Specified by:

getValues in interface backtype.storm.tuple.ITuple

getSourceGlobalStreamid

public backtype.storm.generated.GlobalStreamId getSourceGlobalStreamid()

Specified by:

getSourceGlobalStreamid in interface backtype.storm.tuple.Tuple

getSourceComponent

public String getSourceComponent()

Specified by:

getSourceComponent in interface backtype.storm.tuple.Tuple

getSourceTask

public int getSourceTask()

Specified by:

getSourceTask in interface backtype.storm.tuple.Tuple

getSourceStreamId

public String getSourceStreamId()

Specified by:

getSourceStreamId in interface backtype.storm.tuple.Tuple

getMessageId

public backtype.storm.tuple.MessageId getMessageId()

Specified by:

getMessageId in interface backtype.storm.tuple.Tuple

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object