public class BackPressureStatus extends Object
Modifier and Type | Field and Description |
---|---|
Collection<Integer> |
bpTasks |
long |
id |
static short |
IDENTIFIER |
Collection<Integer> |
nonBpTasks |
String |
workerId |
Constructor and Description |
---|
BackPressureStatus() |
BackPressureStatus(String workerId,
Collection<Integer> bpTasks,
Collection<Integer> nonBpTasks)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
org.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) |
String |
toString() |
public static final short IDENTIFIER
public final long id
public String workerId
public Collection<Integer> bpTasks
public Collection<Integer> nonBpTasks
public BackPressureStatus()
public BackPressureStatus(String workerId, Collection<Integer> bpTasks, Collection<Integer> nonBpTasks)
Constructor.
public static BackPressureStatus read(byte[] bytes, KryoValuesDeserializer deserializer)
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[] *
IOException
Copyright © 2022 The Apache Software Foundation. All rights reserved.