Package | Description |
---|---|
org.apache.storm.daemon.worker | |
org.apache.storm.messaging | |
org.apache.storm.messaging.netty |
Modifier and Type | Method and Description |
---|---|
BackPressureStatus |
BackPressureTracker.getCurrStatus() |
Modifier and Type | Method and Description |
---|---|
void |
IConnection.sendBackPressureStatus(BackPressureStatus bpStatus)
Sends the back pressure metrics to all downstream connections.
|
Modifier and Type | Method and Description |
---|---|
static BackPressureStatus |
BackPressureStatus.read(byte[] bytes,
KryoValuesDeserializer deserializer) |
Modifier and Type | Method and Description |
---|---|
protected void |
BackPressureStatusEncoder.encode(org.apache.storm.shade.io.netty.channel.ChannelHandlerContext ctx,
BackPressureStatus msg,
List<Object> out) |
void |
Client.sendBackPressureStatus(BackPressureStatus bpStatus) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.