public class ExecutorTransfer extends Object
| Constructor and Description |
|---|
ExecutorTransfer(WorkerState workerData,
Map<String,Object> topoConf) |
| Modifier and Type | Method and Description |
|---|---|
void |
flush() |
JCQueue |
getLocalQueue(AddressedTuple tuple) |
void |
initLocalRecvQueues() |
boolean |
tryTransfer(AddressedTuple addressedTuple,
Queue<AddressedTuple> pendingEmits) |
boolean |
tryTransferLocal(AddressedTuple tuple,
JCQueue localQueue,
Queue<AddressedTuple> pendingEmits)
Adds tuple to localQueue (if overflow is empty).
|
public ExecutorTransfer(WorkerState workerData, Map<String,Object> topoConf)
public void initLocalRecvQueues()
public boolean tryTransfer(AddressedTuple addressedTuple, Queue<AddressedTuple> pendingEmits)
public void flush()
throws InterruptedException
InterruptedExceptionpublic JCQueue getLocalQueue(AddressedTuple tuple)
public 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.
Copyright © 2021 The Apache Software Foundation. All rights reserved.