Uses of Class
org.apache.storm.messaging.netty.BackPressureStatus
-
Packages that use BackPressureStatus Package Description org.apache.storm.daemon.worker org.apache.storm.messaging org.apache.storm.messaging.netty -
-
Uses of BackPressureStatus in org.apache.storm.daemon.worker
Methods in org.apache.storm.daemon.worker that return BackPressureStatus Modifier and Type Method Description BackPressureStatus
BackPressureTracker. getCurrStatus()
-
Uses of BackPressureStatus in org.apache.storm.messaging
Methods in org.apache.storm.messaging with parameters of type BackPressureStatus Modifier and Type Method Description void
IConnection. sendBackPressureStatus(BackPressureStatus bpStatus)
Sends the back pressure metrics to all downstream connections. -
Uses of BackPressureStatus in org.apache.storm.messaging.netty
Methods in org.apache.storm.messaging.netty that return BackPressureStatus Modifier and Type Method Description static BackPressureStatus
BackPressureStatus. read(byte[] bytes, KryoValuesDeserializer deserializer)
Methods in org.apache.storm.messaging.netty with parameters of type BackPressureStatus Modifier and Type Method Description protected void
BackPressureStatusEncoder. encode(org.apache.storm.shade.io.netty.channel.ChannelHandlerContext ctx, BackPressureStatus msg, List<Object> out)
void
Client. sendBackPressureStatus(BackPressureStatus bpStatus)
-