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 intBROADCAST_DESTDestination used when broadcasting a tuple.intdestTupletuple
-
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 AddressedTuplecreateFlushTuple(GeneralTopologyContext workerTopologyContext)intgetDest()TuplegetTuple()StringtoString()
-
-
-
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()
-
-