Package org.apache.storm.messaging.netty
Class BackPressureStatus
java.lang.Object
org.apache.storm.messaging.netty.BackPressureStatus
-
Field Summary
Modifier and TypeFieldDescriptionfinal long
static final short
-
Constructor Summary
ConstructorDescriptionBackPressureStatus
(String workerId, Collection<Integer> bpTasks, Collection<Integer> nonBpTasks) Constructor. -
Method Summary
Modifier and TypeMethodDescriptionorg.apache.storm.shade.io.netty.buffer.ByteBuf
buffer
(org.apache.storm.shade.io.netty.buffer.ByteBufAllocator alloc, KryoValuesSerializer ser) Encoded as -600 ... short(2) len ... int(4) payload ... byte[] *static BackPressureStatus
read
(byte[] bytes, KryoValuesDeserializer deserializer) toString()
-
Field Details
-
IDENTIFIER
public static final short IDENTIFIER- See Also:
-
id
public final long id -
workerId
-
bpTasks
-
nonBpTasks
-
-
Constructor Details
-
BackPressureStatus
public BackPressureStatus() -
BackPressureStatus
public BackPressureStatus(String workerId, Collection<Integer> bpTasks, Collection<Integer> nonBpTasks) Constructor.
-
-
Method Details
-
read
-
toString
-
buffer
public org.apache.storm.shade.io.netty.buffer.ByteBuf buffer(org.apache.storm.shade.io.netty.buffer.ByteBufAllocator alloc, KryoValuesSerializer ser) throws IOException Encoded as -600 ... short(2) len ... int(4) payload ... byte[] *- Throws:
IOException
-