Package org.apache.storm.daemon.worker
Class BackPressureTracker
java.lang.Object
org.apache.storm.daemon.worker.BackPressureTracker
Tracks the BackPressure status.
- 
Nested Class SummaryNested Classes
- 
Constructor SummaryConstructorsConstructorDescriptionBackPressureTracker(String workerId, Map<Integer, JCQueue> localTasksToQueues, StormMetricRegistry metricRegistry, Map<Integer, String> taskToComponent) 
- 
Method SummaryModifier and TypeMethodDescriptiongetBackpressureState(Integer taskId) intbooleanRecord BP for a task.booleanvoidsetLastOverflowCount(BackPressureTracker.BackpressureState state, int value) 
- 
Constructor Details- 
BackPressureTracker
 
- 
- 
Method Details- 
getBackpressureState
- 
recordBackPressureRecord 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
 
- 
refreshBpTaskListpublic boolean refreshBpTaskList()
- 
getCurrStatus
- 
getLastOverflowCount
- 
setLastOverflowCount
 
-