org.apache.flink.runtime.io.disk.iomanager

Interface RequestDoneCallback<T>

All Known Implementing Classes:

CompressedBlockChannelReader, CompressedHeaderlessChannelReaderInputView, QueuingCallback

public interface RequestDoneCallback<T>

Callback to be executed on completion of an asynchronous I/O request.

Depending on success or failure, either requestSuccessful(Object) or requestSuccessful(Object) is called.

Method Summary

Modifier and Type	Method and Description
void	requestFailed(T buffer, IOException e)
void	requestSuccessful(T request)

Method Detail

requestSuccessful

void requestSuccessful(T request)

requestFailed

void requestFailed(T buffer,
                   IOException e)