Interface ColumnWriter

All Superinterfaces:
AutoCloseable, SafeCloseable

public interface ColumnWriter extends SafeCloseable
  • Method Summary

    Modifier and Type
    Method
    Description
    void
    addDictionaryPage(@NotNull Object dictionaryValues, int valuesCount)
    Add a dictionary page to the file.
    void
    addPage(Object pageData, int valuesCount, org.apache.parquet.column.statistics.Statistics<?> statistics)
    Add a page (potentially containing nulls) to the file.
    void
    addPageNoNulls(@NotNull Object pageData, int valuesCount, @NotNull org.apache.parquet.column.statistics.Statistics<?> statistics)
    Add a page with no nulls to the file.
    void
    addVectorPage(@NotNull Object pageData, @NotNull IntBuffer repeatCount, int valuesCount, @NotNull org.apache.parquet.column.statistics.Statistics<?> statistics)
    Add a vector page to the file.
    org.apache.parquet.column.statistics.Statistics<?>
    Return the current statistics.
    void
    Reset the statistics for this column.

    Methods inherited from interface io.deephaven.util.SafeCloseable

    close
  • Method Details

    • addPageNoNulls

      void addPageNoNulls(@NotNull @NotNull Object pageData, int valuesCount, @NotNull @NotNull org.apache.parquet.column.statistics.Statistics<?> statistics) throws IOException
      Add a page with no nulls to the file.
      Throws:
      IOException
    • addDictionaryPage

      void addDictionaryPage(@NotNull @NotNull Object dictionaryValues, int valuesCount) throws IOException
      Add a dictionary page to the file.
      Throws:
      IOException
    • addPage

      void addPage(Object pageData, int valuesCount, org.apache.parquet.column.statistics.Statistics<?> statistics) throws IOException
      Add a page (potentially containing nulls) to the file.
      Throws:
      IOException
    • addVectorPage

      void addVectorPage(@NotNull @NotNull Object pageData, @NotNull @NotNull IntBuffer repeatCount, int valuesCount, @NotNull @NotNull org.apache.parquet.column.statistics.Statistics<?> statistics) throws IOException
      Add a vector page to the file.
      Throws:
      IOException
    • resetStats

      void resetStats()
      Reset the statistics for this column. This must be called between each row group.
    • getStats

      org.apache.parquet.column.statistics.Statistics<?> getStats()
      Return the current statistics.