org.apache.flink.runtime.io.disk

Class FileChannelManagerImpl

java.lang.Object

org.apache.flink.runtime.io.disk.FileChannelManagerImpl

All Implemented Interfaces:

AutoCloseable, FileChannelManager

public class FileChannelManagerImpl
extends Object
implements FileChannelManager

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

Constructor Summary

Constructors

Constructor and Description
FileChannelManagerImpl(String[] tempDirs, String prefix)

Method Summary

Modifier and Type	Method and Description
void	close() Remove all the temp directories.
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 class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FileChannelManagerImpl

public FileChannelManagerImpl(String[] tempDirs,
                              String prefix)

Method Detail

createChannel

public FileIOChannel.ID createChannel()

Description copied from interface: FileChannelManager

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

Specified by:

createChannel in interface FileChannelManager

createChannelEnumerator

public FileIOChannel.Enumerator createChannelEnumerator()

Description copied from interface: FileChannelManager

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

Specified by:

createChannelEnumerator in interface FileChannelManager

getPaths

public File[] getPaths()

Description copied from interface: FileChannelManager

Gets all the files corresponding to the config temp dirs.

Specified by:

getPaths in interface FileChannelManager

close

public void close()
           throws Exception

Remove all the temp directories.

Specified by:

close in interface AutoCloseable

Throws:

Exception