Package org.apache.storm.messaging.netty
Class BackPressureStatus
java.lang.Object
org.apache.storm.messaging.netty.BackPressureStatus
- 
Field SummaryFieldsModifier and TypeFieldDescriptionfinal longstatic final short
- 
Constructor SummaryConstructorsConstructorDescriptionBackPressureStatus(String workerId, Collection<Integer> bpTasks, Collection<Integer> nonBpTasks) Constructor.
- 
Method SummaryModifier and TypeMethodDescriptionorg.apache.storm.shade.io.netty.buffer.ByteBufbuffer(org.apache.storm.shade.io.netty.buffer.ByteBufAllocator alloc, KryoValuesSerializer ser) Encoded as -600 ...static BackPressureStatusread(byte[] bytes, KryoValuesDeserializer deserializer) toString()
- 
Field Details- 
IDENTIFIERpublic static final short IDENTIFIER- See Also:
 
- 
idpublic final long id
- 
workerId
- 
bpTasks
- 
nonBpTasks
 
- 
- 
Constructor Details- 
BackPressureStatuspublic BackPressureStatus()
- 
BackPressureStatuspublic BackPressureStatus(String workerId, Collection<Integer> bpTasks, Collection<Integer> nonBpTasks) Constructor.
 
- 
- 
Method Details- 
read
- 
toString
- 
bufferpublic 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
 
 
-