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

Constructor Summary

Constructors

Constructor and Description
AddressedTuple(int dest, Tuple tuple)

Method Summary

Modifier and Type	Method and 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 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()

toString

public String toString()

Overrides:

toString in class Object