| 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 © 2021 The Apache Software Foundation. All rights reserved.