Interface FileIO

  • All Superinterfaces:
    java.io.Serializable
    All Known Implementing Classes:
    HadoopFileIO, S3FileIO

    public interface FileIO
    extends java.io.Serializable
    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 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.
      • initialize

        default void initialize​(java.util.Map<java.lang.String,​java.lang.String> properties)
        Initialize File IO from catalog properties.
        Parameters:
        properties - catalog properties