Uses of Class
org.apache.storm.messaging.netty.BackPressureStatus
Package
Description
-
Uses of BackPressureStatus in org.apache.storm.daemon.worker
-
Uses of BackPressureStatus in org.apache.storm.messaging
Modifier and TypeMethodDescriptionvoid
IConnection.sendBackPressureStatus
(BackPressureStatus bpStatus) Sends the back pressure metrics to all downstream connections. -
Uses of BackPressureStatus in org.apache.storm.messaging.netty
Modifier and TypeMethodDescriptionstatic BackPressureStatus
BackPressureStatus.read
(byte[] bytes, KryoValuesDeserializer deserializer) Modifier and TypeMethodDescriptionprotected void
BackPressureStatusEncoder.encode
(org.apache.storm.shade.io.netty.channel.ChannelHandlerContext ctx, BackPressureStatus msg, List<Object> out) void
Client.sendBackPressureStatus
(BackPressureStatus bpStatus)