org.apache.storm.daemon.worker

Class BackPressureTracker

java.lang.Object

org.apache.storm.daemon.worker.BackPressureTracker

public class BackPressureTracker
extends Object

Tracks the BackPressure status.

Constructor Summary

Constructors

Constructor and Description
BackPressureTracker(String workerId, Map<Integer,JCQueue> localTasksToQueues)

Method Summary

Modifier and Type	Method and Description
BackPressureStatus	getCurrStatus()
boolean	recordBackPressure(Integer taskId) Record BP for a task.
boolean	refreshBpTaskList()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BackPressureTracker

public BackPressureTracker(String workerId,
                           Map<Integer,JCQueue> localTasksToQueues)

Method Detail

recordBackPressure

public boolean recordBackPressure(Integer taskId)

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

public BackPressureStatus getCurrStatus()