@Internal public interface ChannelStateReader extends AutoCloseable
Modifier and Type | Interface and Description |
---|---|
static class |
ChannelStateReader.ReadResult
Status of reading result.
|
Modifier and Type | Field and Description |
---|---|
static ChannelStateReader |
NO_OP |
Modifier and Type | Method and Description |
---|---|
void |
close() |
boolean |
hasChannelStates()
Return whether there are any channel states to be read.
|
ChannelStateReader.ReadResult |
readInputData(InputChannelInfo info,
Buffer buffer)
Put data into the supplied buffer to be injected into
InputChannel . |
ChannelStateReader.ReadResult |
readOutputData(ResultSubpartitionInfo info,
BufferBuilder bufferBuilder)
Put data into the supplied buffer to be injected into
ResultSubpartition . |
static final ChannelStateReader NO_OP
boolean hasChannelStates()
ChannelStateReader.ReadResult readInputData(InputChannelInfo info, Buffer buffer) throws IOException
InputChannel
.IOException
ChannelStateReader.ReadResult readOutputData(ResultSubpartitionInfo info, BufferBuilder bufferBuilder) throws IOException
ResultSubpartition
.IOException
void close() throws Exception
close
in interface AutoCloseable
Exception
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.