Package org.apache.storm.daemon.worker
Class WorkerTransfer
java.lang.Object
org.apache.storm.daemon.worker.WorkerTransfer
- All Implemented Interfaces:
org.apache.storm.shade.org.jctools.queues.MessagePassingQueue.Consumer<Object>,JCQueue.Consumer
-
Constructor Summary
ConstructorsConstructorDescriptionWorkerTransfer(WorkerState workerState, Map<String, Object> topologyConf, int maxTaskIdInTopo) -
Method Summary
Modifier and TypeMethodDescriptionvoidvoidflush()voidvoidbooleanbooleantryTransferRemote(AddressedTuple addressedTuple, Queue<AddressedTuple> pendingEmits, ITupleSerializer serializer)
-
Constructor Details
-
WorkerTransfer
public WorkerTransfer(WorkerState workerState, Map<String, Object> topologyConf, int maxTaskIdInTopo)
-
-
Method Details
-
getTransferQueue
-
makeTransferThread
-
accept
- Specified by:
acceptin interfaceJCQueue.Consumer- Specified by:
acceptin interfaceorg.apache.storm.shade.org.jctools.queues.MessagePassingQueue.Consumer<Object>
-
flush
- Specified by:
flushin interfaceJCQueue.Consumer- Throws:
InterruptedException
-
tryTransferRemote
public boolean tryTransferRemote(AddressedTuple addressedTuple, Queue<AddressedTuple> pendingEmits, ITupleSerializer serializer) -
flushRemotes
- Throws:
InterruptedException
-
tryFlushRemotes
public boolean tryFlushRemotes() -
haltTransferThd
public void haltTransferThd()
-