Package org.apache.storm.executor
Class ExecutorTransfer
java.lang.Object
org.apache.storm.executor.ExecutorTransfer
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionvoidflush()getLocalQueue(AddressedTuple tuple) voidbooleantryTransfer(AddressedTuple addressedTuple, Queue<AddressedTuple> pendingEmits) booleantryTransferLocal(AddressedTuple tuple, JCQueue localQueue, Queue<AddressedTuple> pendingEmits) Adds tuple to localQueue (if overflow is empty).
- 
Constructor Details- 
ExecutorTransfer
 
- 
- 
Method Details- 
initLocalRecvQueuespublic void initLocalRecvQueues()
- 
tryTransfer
- 
flush- Throws:
- InterruptedException
 
- 
getLocalQueue
- 
tryTransferLocalpublic boolean tryTransferLocal(AddressedTuple tuple, JCQueue localQueue, Queue<AddressedTuple> pendingEmits) Adds tuple to localQueue (if overflow is empty). If localQueue is full adds to pendingEmits instead. pendingEmits can be null. Returns false if unable to add to localQueue.
 
-