Class RollingDataWriter<T>

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable, FileWriter<T,​DataWriteResult>

    public class RollingDataWriter<T>
    extends java.lang.Object
    A rolling data writer that splits incoming data into multiple files within one spec/partition based on the target file size.
    • Method Detail

      • currentFilePath

        public java.lang.CharSequence currentFilePath()
      • currentFileRows

        public long currentFileRows()
      • length

        public long length()
        Description copied from interface: FileWriter
        Returns the number of bytes that were currently written by this writer.
        Specified by:
        length in interface FileWriter<T,​W extends FileWriter<T,​R>>
        Returns:
        the number of written bytes
      • write

        public void write​(T row)
        Description copied from interface: FileWriter
        Writes a row to a predefined spec/partition.
        Specified by:
        write in interface FileWriter<T,​W extends FileWriter<T,​R>>
        Parameters:
        row - a data or delete record
      • openCurrentWriter

        protected void openCurrentWriter()
      • close

        public void close()
                   throws java.io.IOException
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface java.io.Closeable
        Throws:
        java.io.IOException
      • result

        public final R result()
        Description copied from interface: FileWriter
        Returns a result that contains information about written DataFiles or DeleteFiles. The result is valid only after the writer is closed.
        Specified by:
        result in interface FileWriter<T,​W extends FileWriter<T,​R>>
        Returns:
        the file writer result