Interface Writer

  • All Superinterfaces:
    java.lang.AutoCloseable, java.io.Closeable
    All Known Implementing Classes:
    ProximaParquetWriter

    public interface Writer
    extends java.io.Closeable
    Proxima's abstraction of writer for bulk data.
    • Method Detail

      • write

        void write​(StreamElement elem)
            throws java.io.IOException
        Write StreamElement into this blob store.
        Parameters:
        elem - the element to write
        Throws:
        java.io.IOException - on errors
      • close

        void close()
            throws java.io.IOException
        Close and flush the writer to target FileSystem. Note that the associated Path might be visible on the target FileSystem only after closing associated writer.
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface java.io.Closeable
        Throws:
        java.io.IOException - on errors
      • getPath

        Path getPath()
        Get Path associated with the Writer.
        Returns:
        the path of this writer