org.apache.iceberg.io

Interface FileIO

All Superinterfaces:

java.lang.AutoCloseable, java.io.Closeable, java.io.Serializable

All Known Implementing Classes:

GCSFileIO, HadoopFileIO, OSSFileIO, ResolvingFileIO, S3FileIO

public interface FileIO
extends java.io.Serializable, java.io.Closeable

Pluggable module for reading, writing, and deleting files.

Both table metadata files and data files can be written and read by this module. Implementations must be serializable because various clients of Spark tables may initialize this once and pass it off to a separate module that would then interact with the streams.

Method Summary

Modifier and Type	Method and Description
default void	close() Close File IO to release underlying resources.
default void	deleteFile(InputFile file) Convenience method to delete an InputFile.
default void	deleteFile(OutputFile file) Convenience method to delete an OutputFile.
void	deleteFile(java.lang.String path) Delete the file at the given path.
default void	initialize(java.util.Map<java.lang.String,java.lang.String> properties) Initialize File IO from catalog properties.
InputFile	newInputFile(java.lang.String path) Get a InputFile instance to read bytes from the file at the given path.
OutputFile	newOutputFile(java.lang.String path) Get a OutputFile instance to write bytes to the file at the given path.

Method Detail

newInputFile

InputFile newInputFile(java.lang.String path)

Get a InputFile instance to read bytes from the file at the given path.

newOutputFile

OutputFile newOutputFile(java.lang.String path)

Get a OutputFile instance to write bytes to the file at the given path.

deleteFile

void deleteFile(java.lang.String path)

Delete the file at the given path.

deleteFile

default void deleteFile(InputFile file)

Convenience method to delete an InputFile.

deleteFile

default void deleteFile(OutputFile file)

Convenience method to delete an OutputFile.

initialize

default void initialize(java.util.Map<java.lang.String,java.lang.String> properties)

Initialize File IO from catalog properties.

Parameters:

properties - catalog properties

close

default void close()

Close File IO to release underlying resources.

Calling this method is only required when this FileIO instance is no longer expected to be used, and the resources it holds need to be explicitly released to avoid resource leaks.

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable