Uses of Class
org.apache.storm.utils.JCQueue
-
Uses of JCQueue in org.apache.storm.daemon.worker
Modifier and TypeMethodDescriptionWorkerState.getTransferQueue()
WorkerTransfer.getTransferQueue()
Modifier and TypeMethodDescriptionWorkerState.getExecutorReceiveQueueMap()
WorkerState.getLocalReceiveQueues()
ModifierConstructorDescriptionBackPressureTracker
(String workerId, Map<Integer, JCQueue> localTasksToQueues, StormMetricRegistry metricRegistry, Map<Integer, String> taskToComponent) -
Uses of JCQueue in org.apache.storm.executor
Modifier and TypeMethodDescriptionExecutorTransfer.getLocalQueue
(AddressedTuple tuple) Executor.getReceiveQueue()
ExecutorShutdown.getReceiveQueue()
IRunningExecutor.getReceiveQueue()
Modifier and TypeMethodDescriptionboolean
ExecutorTransfer.tryTransferLocal
(AddressedTuple tuple, JCQueue localQueue, Queue<AddressedTuple> pendingEmits) Adds tuple to localQueue (if overflow is empty).ModifierConstructorDescriptionExecutorShutdown
(Executor executor, List<Utils.SmartThread> threads, ArrayList<Task> taskDatas, JCQueue recvQueue)