Package org.apache.flink.runtime.checkpoint.channel

Interface SequentialChannelStateReader

All Superinterfaces:

AutoCloseable

All Known Implementing Classes:

SequentialChannelStateReaderImpl

@Internal
public interface SequentialChannelStateReader
extends AutoCloseable

Reads channel state saved during checkpoint/savepoint.

Field Summary

Fields

Modifier and Type	Field	Description
static SequentialChannelStateReader	NO_OP

Method Summary

Modifier and Type	Method	Description
void	close()
void	readInputData(InputGate[] inputGates)
void	readOutputData(ResultPartitionWriter[] writers, boolean notifyAndBlockOnCompletion)

Field Detail

NO_OP

static final SequentialChannelStateReader NO_OP

Method Detail

readInputData

void readInputData(InputGate[] inputGates)
            throws IOException,
                   InterruptedException

Throws:

IOException

InterruptedException

readOutputData

void readOutputData(ResultPartitionWriter[] writers,
                    boolean notifyAndBlockOnCompletion)
             throws IOException,
                    InterruptedException

Throws:

IOException

InterruptedException

close

void close()
    throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception