org.apache.flink.runtime.io.disk

Interface FileChannelManager

All Superinterfaces:

AutoCloseable

All Known Implementing Classes:

FileChannelManagerImpl

public interface FileChannelManager
extends AutoCloseable

The manager used for creating/getting file IO channels based on config temp dirs.

Method Summary

Modifier and Type	Method and Description
FileIOChannel.ID	createChannel() Creates an ID identifying an underlying file channel and returns it.
FileIOChannel.Enumerator	createChannelEnumerator() Creates an enumerator for channels that logically belong together and returns it.
File[]	getPaths() Gets all the files corresponding to the config temp dirs.

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

createChannel

FileIOChannel.ID createChannel()

Creates an ID identifying an underlying file channel and returns it.

createChannelEnumerator

FileIOChannel.Enumerator createChannelEnumerator()

Creates an enumerator for channels that logically belong together and returns it.

getPaths

File[] getPaths()

Gets all the files corresponding to the config temp dirs.