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 final int	BROADCAST_DEST	Destination used when broadcasting a tuple.
final int	dest
final Tuple	tuple

Constructor Summary

Constructors

Constructor	Description
AddressedTuple(int dest, Tuple tuple)

Method Summary

Modifier and Type	Method	Description
static AddressedTuple	createFlushTuple(GeneralTopologyContext workerTopologyContext)
int	getDest()
Tuple	getTuple()
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

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 Details

AddressedTuple

public AddressedTuple(int dest,
 Tuple tuple)

Method Details

createFlushTuple

public static AddressedTuple createFlushTuple(GeneralTopologyContext workerTopologyContext)

getTuple

public Tuple getTuple()

getDest

public int getDest()

toString

public String toString()

Overrides:

toString in class Object