Uses of Class
org.apache.storm.tuple.AddressedTuple

Packages that use AddressedTuple

Package	Description
org.apache.storm.daemon
org.apache.storm.daemon.worker
org.apache.storm.executor
org.apache.storm.tuple

Uses of AddressedTuple in org.apache.storm.daemon

Method parameters in org.apache.storm.daemon with type arguments of type AddressedTuple

Modifier and Type	Method and Description
void	Task.sendToEventLogger(Executor executor, List values, String componentId, Object messageId, Random random, Queue<AddressedTuple> overflow) Send sampled data to the eventlogger if the global or component level debug flag is set (via nimbus api).
void	Task.sendUnanchored(String stream, List<Object> values, ExecutorTransfer transfer, Queue<AddressedTuple> pendingEmits)

Uses of AddressedTuple in org.apache.storm.daemon.worker

Methods in org.apache.storm.daemon.worker with parameters of type AddressedTuple

Modifier and Type	Method and Description
void	WorkerState.checkSerialize(KryoTupleSerializer serializer, AddressedTuple tuple)
boolean	WorkerState.tryTransferRemote(AddressedTuple tuple, Queue<AddressedTuple> pendingEmits, ITupleSerializer serializer)

Method parameters in org.apache.storm.daemon.worker with type arguments of type AddressedTuple

Modifier and Type	Method and Description
void	WorkerState.ILocalTransferCallback.transfer(ArrayList<AddressedTuple> tupleBatch)
boolean	WorkerState.tryTransferRemote(AddressedTuple tuple, Queue<AddressedTuple> pendingEmits, ITupleSerializer serializer)

Uses of AddressedTuple in org.apache.storm.executor

Fields in org.apache.storm.executor with type parameters of type AddressedTuple

Modifier and Type	Field and Description
protected org.apache.storm.shade.org.jctools.queues.MpscChunkedArrayQueue<AddressedTuple>	Executor.pendingEmits

Methods in org.apache.storm.executor that return types with arguments of type AddressedTuple

Modifier and Type	Method and Description
Queue<AddressedTuple>	Executor.getPendingEmits()

Methods in org.apache.storm.executor with parameters of type AddressedTuple

Modifier and Type	Method and Description
JCQueue	ExecutorTransfer.getLocalQueue(AddressedTuple tuple)
boolean	ExecutorTransfer.tryTransfer(AddressedTuple addressedTuple, Queue<AddressedTuple> pendingEmits)
boolean	ExecutorTransfer.tryTransferLocal(AddressedTuple tuple, JCQueue localQueue, Queue<AddressedTuple> pendingEmits) Adds tuple to localQueue (if overflow is empty).

Method parameters in org.apache.storm.executor with type arguments of type AddressedTuple

Modifier and Type	Method and Description
boolean	ExecutorTransfer.tryTransfer(AddressedTuple addressedTuple, Queue<AddressedTuple> pendingEmits)
boolean	ExecutorTransfer.tryTransferLocal(AddressedTuple tuple, JCQueue localQueue, Queue<AddressedTuple> pendingEmits) Adds tuple to localQueue (if overflow is empty).

Uses of AddressedTuple in org.apache.storm.tuple

Methods in org.apache.storm.tuple that return AddressedTuple

Modifier and Type	Method and Description
static AddressedTuple	AddressedTuple.createFlushTuple(GeneralTopologyContext workerTopologyContext)