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