Package | Description |
---|---|
org.apache.storm.daemon.worker |
Modifier and Type | Method and Description |
---|---|
BackPressureTracker.BackpressureState |
BackPressureTracker.getBackpressureState(Integer taskId) |
Modifier and Type | Method and Description |
---|---|
int |
BackPressureTracker.getLastOverflowCount(BackPressureTracker.BackpressureState state) |
boolean |
BackPressureTracker.recordBackPressure(BackPressureTracker.BackpressureState state)
Record BP for a task.
|
void |
BackPressureTracker.setLastOverflowCount(BackPressureTracker.BackpressureState state,
int value) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.