Uses of Class
org.apache.storm.utils.JCQueue

Packages that use JCQueue

Package	Description
org.apache.storm.daemon.worker
org.apache.storm.executor

Uses of JCQueue in org.apache.storm.daemon.worker

Methods in org.apache.storm.daemon.worker that return JCQueue

Modifier and Type	Method	Description
JCQueue	WorkerState.getTransferQueue()
JCQueue	WorkerTransfer.getTransferQueue()

Methods in org.apache.storm.daemon.worker that return types with arguments of type JCQueue

Modifier and Type	Method	Description
Map<List<Long>,JCQueue>	WorkerState.getExecutorReceiveQueueMap()
Map<Integer,JCQueue>	WorkerState.getLocalReceiveQueues()

Constructor parameters in org.apache.storm.daemon.worker with type arguments of type JCQueue

Constructor	Description
BackPressureTracker(String workerId, Map<Integer,JCQueue> localTasksToQueues, StormMetricRegistry metricRegistry, Map<Integer,String> taskToComponent)

Uses of JCQueue in org.apache.storm.executor

Fields in org.apache.storm.executor declared as JCQueue

Modifier and Type	Field	Description
protected JCQueue	Executor.receiveQueue

Methods in org.apache.storm.executor that return JCQueue

Modifier and Type	Method	Description
JCQueue	ExecutorTransfer.getLocalQueue(AddressedTuple tuple)
JCQueue	Executor.getReceiveQueue()
JCQueue	ExecutorShutdown.getReceiveQueue()
JCQueue	IRunningExecutor.getReceiveQueue()

Methods in org.apache.storm.executor with parameters of type JCQueue

Modifier and Type	Method	Description
boolean	ExecutorTransfer.tryTransferLocal(AddressedTuple tuple, JCQueue localQueue, Queue<AddressedTuple> pendingEmits)	Adds tuple to localQueue (if overflow is empty).

Constructors in org.apache.storm.executor with parameters of type JCQueue

Constructor	Description
ExecutorShutdown(Executor executor, List<Utils.SmartThread> threads, ArrayList<Task> taskDatas, JCQueue recvQueue)