Package org.apache.storm.daemon.worker
Class BackPressureTracker
java.lang.Object
org.apache.storm.daemon.worker.BackPressureTracker
Tracks the BackPressure status.
-
Nested Class Summary
-
Constructor Summary
ConstructorDescriptionBackPressureTracker
(String workerId, Map<Integer, JCQueue> localTasksToQueues, StormMetricRegistry metricRegistry, Map<Integer, String> taskToComponent) -
Method Summary
Modifier and TypeMethodDescriptiongetBackpressureState
(Integer taskId) int
boolean
Record BP for a task.boolean
void
setLastOverflowCount
(BackPressureTracker.BackpressureState state, int value)
-
Constructor Details
-
BackPressureTracker
-
-
Method Details
-
getBackpressureState
-
recordBackPressure
Record BP for a task.This is called by transferLocalBatch() on NettyWorker thread
- Returns:
- true if an update was recorded, false if taskId is already under BP
-
refreshBpTaskList
public boolean refreshBpTaskList() -
getCurrStatus
-
getLastOverflowCount
-
setLastOverflowCount
-