public class WorkerTransfer extends Object implements JCQueue.Consumer
| Constructor and Description |
|---|
WorkerTransfer(WorkerState workerState,
Map<String,Object> topologyConf,
int maxTaskIdInTopo) |
| Modifier and Type | Method and Description |
|---|---|
void |
accept(Object tuple) |
void |
flush() |
void |
flushRemotes() |
JCQueue |
getTransferQueue() |
void |
haltTransferThd() |
Utils.SmartThread |
makeTransferThread() |
boolean |
tryFlushRemotes() |
boolean |
tryTransferRemote(AddressedTuple addressedTuple,
Queue<AddressedTuple> pendingEmits,
ITupleSerializer serializer) |
public WorkerTransfer(WorkerState workerState, Map<String,Object> topologyConf, int maxTaskIdInTopo)
public JCQueue getTransferQueue()
public Utils.SmartThread makeTransferThread()
public void accept(Object tuple)
accept in interface org.apache.storm.shade.org.jctools.queues.MessagePassingQueue.Consumer<Object>accept in interface JCQueue.Consumerpublic void flush()
throws InterruptedException
flush in interface JCQueue.ConsumerInterruptedExceptionpublic boolean tryTransferRemote(AddressedTuple addressedTuple, Queue<AddressedTuple> pendingEmits, ITupleSerializer serializer)
public void flushRemotes()
throws InterruptedException
InterruptedExceptionpublic boolean tryFlushRemotes()
public void haltTransferThd()
Copyright © 2021 The Apache Software Foundation. All rights reserved.