Uses of Class
org.apache.storm.messaging.netty.BackPressureStatus
Packages that use BackPressureStatus
Package
Description
-
Uses of BackPressureStatus in org.apache.storm.daemon.worker
Methods in org.apache.storm.daemon.worker that return BackPressureStatus -
Uses of BackPressureStatus in org.apache.storm.messaging
Methods in org.apache.storm.messaging with parameters of type BackPressureStatusModifier and TypeMethodDescriptionvoid
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 BackPressureStatusModifier and TypeMethodDescriptionstatic BackPressureStatus
BackPressureStatus.read
(byte[] bytes, KryoValuesDeserializer deserializer) Methods in org.apache.storm.messaging.netty with parameters of type BackPressureStatusModifier and TypeMethodDescriptionprotected void
BackPressureStatusEncoder.encode
(org.apache.storm.shade.io.netty.channel.ChannelHandlerContext ctx, BackPressureStatus msg, List<Object> out) void
Client.sendBackPressureStatus
(BackPressureStatus bpStatus)