org.apache.flink.storm.wrappers

Class StormTuple<IN>

java.lang.Object

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

All Implemented Interfaces:

org.apache.storm.tuple.ITuple, org.apache.storm.tuple.Tuple

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

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

Constructor Summary

Constructors

Constructor and Description
StormTuple(IN flinkTuple, org.apache.storm.tuple.Fields schema, int producerTaskId, String producerStreamId, String producerComponentId, org.apache.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)
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()
Short	getShort(int i)
Short	getShortByField(String field)
String	getSourceComponent()
org.apache.storm.generated.GlobalStreamId	getSourceGlobalStreamid()
org.apache.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(org.apache.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,
                  org.apache.storm.tuple.Fields schema,
                  int producerTaskId,
                  String producerStreamId,
                  String producerComponentId,
                  org.apache.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 org.apache.storm.tuple.ITuple

contains

public boolean contains(String field)

Specified by:

contains in interface org.apache.storm.tuple.ITuple

getFields

public org.apache.storm.tuple.Fields getFields()

Specified by:

getFields in interface org.apache.storm.tuple.ITuple

fieldIndex

public int fieldIndex(String field)

Specified by:

fieldIndex in interface org.apache.storm.tuple.ITuple

select

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

Specified by:

select in interface org.apache.storm.tuple.ITuple

getValue

public Object getValue(int i)

Specified by:

getValue in interface org.apache.storm.tuple.ITuple

getString

public String getString(int i)

Specified by:

getString in interface org.apache.storm.tuple.ITuple

getInteger

public Integer getInteger(int i)

Specified by:

getInteger in interface org.apache.storm.tuple.ITuple

getLong

public Long getLong(int i)

Specified by:

getLong in interface org.apache.storm.tuple.ITuple

getBoolean

public Boolean getBoolean(int i)

Specified by:

getBoolean in interface org.apache.storm.tuple.ITuple

getShort

public Short getShort(int i)

Specified by:

getShort in interface org.apache.storm.tuple.ITuple

getByte

public Byte getByte(int i)

Specified by:

getByte in interface org.apache.storm.tuple.ITuple

getDouble

public Double getDouble(int i)

Specified by:

getDouble in interface org.apache.storm.tuple.ITuple

getFloat

public Float getFloat(int i)

Specified by:

getFloat in interface org.apache.storm.tuple.ITuple

getBinary

public byte[] getBinary(int i)

Specified by:

getBinary in interface org.apache.storm.tuple.ITuple

getValueByName

public <T> T getValueByName(String field)

getValueByField

public Object getValueByField(String field)

Specified by:

getValueByField in interface org.apache.storm.tuple.ITuple

getStringByField

public String getStringByField(String field)

Specified by:

getStringByField in interface org.apache.storm.tuple.ITuple

getIntegerByField

public Integer getIntegerByField(String field)

Specified by:

getIntegerByField in interface org.apache.storm.tuple.ITuple

getLongByField

public Long getLongByField(String field)

Specified by:

getLongByField in interface org.apache.storm.tuple.ITuple

getBooleanByField

public Boolean getBooleanByField(String field)

Specified by:

getBooleanByField in interface org.apache.storm.tuple.ITuple

getShortByField

public Short getShortByField(String field)

Specified by:

getShortByField in interface org.apache.storm.tuple.ITuple

getByteByField

public Byte getByteByField(String field)

Specified by:

getByteByField in interface org.apache.storm.tuple.ITuple

getDoubleByField

public Double getDoubleByField(String field)

Specified by:

getDoubleByField in interface org.apache.storm.tuple.ITuple

getFloatByField

public Float getFloatByField(String field)

Specified by:

getFloatByField in interface org.apache.storm.tuple.ITuple

getBinaryByField

public byte[] getBinaryByField(String field)

Specified by:

getBinaryByField in interface org.apache.storm.tuple.ITuple

getValues

public List<Object> getValues()

Specified by:

getValues in interface org.apache.storm.tuple.ITuple

getSourceGlobalStreamid

public org.apache.storm.generated.GlobalStreamId getSourceGlobalStreamid()

Specified by:

getSourceGlobalStreamid in interface org.apache.storm.tuple.Tuple

getSourceComponent

public String getSourceComponent()

Specified by:

getSourceComponent in interface org.apache.storm.tuple.Tuple

getSourceTask

public int getSourceTask()

Specified by:

getSourceTask in interface org.apache.storm.tuple.Tuple

getSourceStreamId

public String getSourceStreamId()

Specified by:

getSourceStreamId in interface org.apache.storm.tuple.Tuple

getMessageId

public org.apache.storm.tuple.MessageId getMessageId()

Specified by:

getMessageId in interface org.apache.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

getSourceGlobalStreamId

public org.apache.storm.generated.GlobalStreamId getSourceGlobalStreamId()

Specified by:

getSourceGlobalStreamId in interface org.apache.storm.tuple.Tuple