@NotThreadSafe @Internal public class ChannelStateReaderImpl extends Object implements ChannelStateReader
ChannelStateReader
implementation. Usage considerations:
NO_MORE_DATA
ChannelStateReader.ReadResult
NO_OP
Constructor and Description |
---|
ChannelStateReaderImpl(TaskStateSnapshot snapshot) |
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 . |
public ChannelStateReaderImpl(TaskStateSnapshot snapshot)
public boolean hasChannelStates()
ChannelStateReader
hasChannelStates
in interface ChannelStateReader
public ChannelStateReader.ReadResult readInputData(InputChannelInfo info, Buffer buffer) throws IOException
ChannelStateReader
InputChannel
.readInputData
in interface ChannelStateReader
IOException
public ChannelStateReader.ReadResult readOutputData(ResultSubpartitionInfo info, BufferBuilder bufferBuilder) throws IOException
ChannelStateReader
ResultSubpartition
.readOutputData
in interface ChannelStateReader
IOException
public void close() throws Exception
close
in interface AutoCloseable
close
in interface ChannelStateReader
Exception
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.