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

Interface BlockChannelWriterWithCallback<T>

All Superinterfaces:

FileIOChannel

All Known Subinterfaces:

BlockChannelWriter<T>, BufferFileWriter

All Known Implementing Classes:

AsynchronousBlockWriter, AsynchronousBlockWriterWithCallback, AsynchronousBufferFileWriter, CompressedBlockChannelWriter

public interface BlockChannelWriterWithCallback<T>
extends FileIOChannel

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.runtime.io.disk.iomanager.FileIOChannel

FileIOChannel.Enumerator, FileIOChannel.ID

Method Summary

Modifier and Type	Method and Description
void	writeBlock(T block) Writes the given block.

Methods inherited from interface org.apache.flink.runtime.io.disk.iomanager.FileIOChannel

close, closeAndDelete, deleteChannel, getChannelID, getNioFileChannel, getSize, isClosed

Method Detail

writeBlock

void writeBlock(T block)
         throws IOException

Writes the given block. The request may be executed synchronously, or asynchronously, depending on the implementation.

Parameters:

block - The segment to be written (transferring ownership to this writer).

Throws:

IOException - Thrown, when the writer encounters an I/O error.