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
InterruptedException
public 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 © 2022 The Apache Software Foundation. All rights reserved.