Package org.apache.storm.tuple
Class AddressedTuple
- java.lang.Object
-
- org.apache.storm.tuple.AddressedTuple
-
public final class AddressedTuple extends Object
A Tuple that is addressed to a destination.
-
-
Field Summary
Fields Modifier and Type Field Description static int
BROADCAST_DEST
Destination used when broadcasting a tuple.int
dest
Tuple
tuple
-
Constructor Summary
Constructors Constructor Description AddressedTuple(int dest, Tuple tuple)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static AddressedTuple
createFlushTuple(GeneralTopologyContext workerTopologyContext)
int
getDest()
Tuple
getTuple()
String
toString()
-
-
-
Field Detail
-
BROADCAST_DEST
public static final int BROADCAST_DEST
Destination used when broadcasting a tuple.- See Also:
- Constant Field Values
-
tuple
public final Tuple tuple
-
dest
public final int dest
-
-
Constructor Detail
-
AddressedTuple
public AddressedTuple(int dest, Tuple tuple)
-
-
Method Detail
-
createFlushTuple
public static AddressedTuple createFlushTuple(GeneralTopologyContext workerTopologyContext)
-
getTuple
public Tuple getTuple()
-
getDest
public int getDest()
-
-