org.apache.paimon.disk

Class IOManagerImpl

java.lang.Object

org.apache.paimon.disk.IOManagerImpl

All Implemented Interfaces:

AutoCloseable, IOManager

public class IOManagerImpl
extends Object
implements IOManager

The facade for the provided I/O manager services.

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
IOManagerImpl(String... tempDirs) Constructs a new IOManager.

Method Summary

Modifier and Type	Method and Description
void	close() Removes all temporary files.
BufferFileReader	createBufferFileReader(FileIOChannel.ID channelID)
BufferFileWriter	createBufferFileWriter(FileIOChannel.ID channelID)
FileIOChannel.ID	createChannel()
FileIOChannel.ID	createChannel(String prefix)
FileIOChannel.Enumerator	createChannelEnumerator()
static void	deleteChannel(FileIOChannel.ID channel) Deletes the file underlying the given channel.
File[]	getSpillingDirectories() Gets the directories that the I/O manager spills to.
String[]	getSpillingDirectoriesPaths() Gets the directories that the I/O manager spills to, as path strings.
static String[]	splitPaths(String separatedPaths)
String[]	tempDirs()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.paimon.disk.IOManager

create, create

Field Detail

LOG

protected static final org.slf4j.Logger LOG

Constructor Detail

IOManagerImpl

public IOManagerImpl(String... tempDirs)

Constructs a new IOManager.

Parameters:

tempDirs - The basic directories for files underlying anonymous channels.

Method Detail

close

public void close()
           throws Exception

Removes all temporary files.

Specified by:

close in interface AutoCloseable

Throws:

Exception

createChannel

public FileIOChannel.ID createChannel()

Specified by:

createChannel in interface IOManager

createChannel

public FileIOChannel.ID createChannel(String prefix)

Specified by:

createChannel in interface IOManager

tempDirs

public String[] tempDirs()

Specified by:

tempDirs in interface IOManager

createChannelEnumerator

public FileIOChannel.Enumerator createChannelEnumerator()

Specified by:

createChannelEnumerator in interface IOManager

deleteChannel

public static void deleteChannel(FileIOChannel.ID channel)

Deletes the file underlying the given channel. If the channel is still open, this call may fail.

Parameters:

channel - The channel to be deleted.

getSpillingDirectories

public File[] getSpillingDirectories()

Gets the directories that the I/O manager spills to.

Returns:

The directories that the I/O manager spills to.

getSpillingDirectoriesPaths

public String[] getSpillingDirectoriesPaths()

Gets the directories that the I/O manager spills to, as path strings.

Returns:

The directories that the I/O manager spills to, as path strings.

createBufferFileWriter

public BufferFileWriter createBufferFileWriter(FileIOChannel.ID channelID)
                                        throws IOException

Specified by:

createBufferFileWriter in interface IOManager

Throws:

IOException

createBufferFileReader

public BufferFileReader createBufferFileReader(FileIOChannel.ID channelID)
                                        throws IOException

Specified by:

createBufferFileReader in interface IOManager

Throws:

IOException

splitPaths

public static String[] splitPaths(@Nonnull
                                  String separatedPaths)