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
ConstructorDescriptionWorkerTransfer
(WorkerState workerState, Map<String, Object> topologyConf, int maxTaskIdInTopo) -
Method Summary
Modifier and TypeMethodDescriptionvoid
void
flush()
void
void
boolean
boolean
tryTransferRemote
(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:
accept
in interfaceJCQueue.Consumer
- Specified by:
accept
in interfaceorg.apache.storm.shade.org.jctools.queues.MessagePassingQueue.Consumer<Object>
-
flush
- Specified by:
flush
in 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()
-