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

Packages that use JCQueue

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

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

Method parameters in org.apache.storm.daemon.metrics with type arguments of type JCQueue

Modifier and Type	Method and Description
static void	BuiltinMetricsUtil.registerQueueMetrics(Map<String,JCQueue> queues, Map<String,Object> topoConf, TopologyContext context)

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

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

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

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

Modifier and Type	Method and 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 and Description
BackPressureTracker(String workerId, Map<Integer,JCQueue> localTasksToQueues)

Uses of JCQueue in org.apache.storm.executor

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

Modifier and Type	Field and Description
protected JCQueue	Executor.receiveQueue

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

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

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

Modifier and Type	Method and 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 and Description
ExecutorShutdown(Executor executor, List<Utils.SmartThread> threads, ArrayList<Task> taskDatas, JCQueue recvQueue)