Uses of Class
org.apache.storm.tuple.AddressedTuple
Package
Description
-
Uses of AddressedTuple in org.apache.storm.daemon
Modifier and TypeMethodDescriptionvoid
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
Modifier and TypeMethodDescriptionvoid
WorkerState.checkSerialize
(KryoTupleSerializer serializer, AddressedTuple tuple) boolean
WorkerState.tryTransferRemote
(AddressedTuple tuple, Queue<AddressedTuple> pendingEmits, ITupleSerializer serializer) boolean
WorkerTransfer.tryTransferRemote
(AddressedTuple addressedTuple, Queue<AddressedTuple> pendingEmits, ITupleSerializer serializer) Modifier and TypeMethodDescriptionvoid
WorkerState.ILocalTransferCallback.transfer
(ArrayList<AddressedTuple> tupleBatch) boolean
WorkerState.tryTransferRemote
(AddressedTuple tuple, Queue<AddressedTuple> pendingEmits, ITupleSerializer serializer) boolean
WorkerTransfer.tryTransferRemote
(AddressedTuple addressedTuple, Queue<AddressedTuple> pendingEmits, ITupleSerializer serializer) -
Uses of AddressedTuple in org.apache.storm.executor
Modifier and TypeFieldDescriptionprotected final org.apache.storm.shade.org.jctools.queues.MpscChunkedArrayQueue<AddressedTuple>
Executor.pendingEmits
Modifier and TypeMethodDescriptionExecutorTransfer.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).Modifier and TypeMethodDescriptionboolean
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
Modifier and TypeMethodDescriptionstatic AddressedTuple
AddressedTuple.createFlushTuple
(GeneralTopologyContext workerTopologyContext)