| Package | Description |
|---|---|
| org.apache.storm.messaging.netty |
| Modifier and Type | Method and Description |
|---|---|
org.apache.storm.shade.io.netty.buffer.ByteBuf |
BackPressureStatus.buffer(org.apache.storm.shade.io.netty.buffer.ByteBufAllocator alloc,
KryoValuesSerializer ser)
Encoded as -600 … short(2) len … int(4) payload … byte[] *
|
| Constructor and Description |
|---|
BackPressureStatusEncoder(KryoValuesSerializer ser) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.