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 BackPressureStatusBackPressureTracker. 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 voidIConnection. 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 BackPressureStatusBackPressureStatus. read(byte[] bytes, KryoValuesDeserializer deserializer)Methods in org.apache.storm.messaging.netty with parameters of type BackPressureStatus Modifier and Type Method Description protected voidBackPressureStatusEncoder. encode(org.apache.storm.shade.io.netty.channel.ChannelHandlerContext ctx, BackPressureStatus msg, List<Object> out)voidClient. sendBackPressureStatus(BackPressureStatus bpStatus)
-