Package io.deephaven.parquet.base

Class ColumnWriterImpl

java.lang.Object
io.deephaven.parquet.base.ColumnWriterImpl
All Implemented Interfaces:
ColumnWriter, SafeCloseable, AutoCloseable
public final class ColumnWriterImpl extends Object implements ColumnWriter

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    addDictionaryPage(@NotNull Object dictionaryValues, int valuesCount)
    Add a dictionary page to the file.
    void
    addPage(@NotNull Object pageData, int valuesCount, @NotNull 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 nonNullValueCount, @NotNull org.apache.parquet.column.statistics.Statistics<?> statistics)
    Add a vector page to the file.
    void
    close()
     
    org.apache.parquet.column.ColumnDescriptor
    getColumn()
     
    org.apache.parquet.column.statistics.Statistics<?>
    getStats()
    Return the current statistics.
    void
    resetStats()
    Reset the statistics for this column.
    void
    writePageV2(int rowCount, int nullCount, int valueCount, org.apache.parquet.bytes.BytesInput repetitionLevels, org.apache.parquet.bytes.BytesInput definitionLevels, ByteBuffer data)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Method Details

    • addPageNoNulls

      public void addPageNoNulls(@NotNull @NotNull Object pageData, int valuesCount, @NotNull @NotNull org.apache.parquet.column.statistics.Statistics<?> statistics) throws IOException
      Description copied from interface: ColumnWriter
      Add a page with no nulls to the file.
      Specified by:
      addPageNoNulls in interface ColumnWriter
      Throws:
      IOException

    • addDictionaryPage

      public void addDictionaryPage(@NotNull @NotNull Object dictionaryValues, int valuesCount) throws IOException
      Description copied from interface: ColumnWriter
      Add a dictionary page to the file.
      Specified by:
      addDictionaryPage in interface ColumnWriter
      Throws:
      IOException

    • addPage

      public void addPage(@NotNull @NotNull Object pageData, int valuesCount, @NotNull @NotNull org.apache.parquet.column.statistics.Statistics<?> statistics) throws IOException
      Description copied from interface: ColumnWriter
      Add a page (potentially containing nulls) to the file.
      Specified by:
      addPage in interface ColumnWriter
      Throws:
      IOException

    • addVectorPage

      public void addVectorPage(@NotNull @NotNull Object pageData, @NotNull @NotNull IntBuffer repeatCount, int nonNullValueCount, @NotNull @NotNull org.apache.parquet.column.statistics.Statistics<?> statistics) throws IOException
      Description copied from interface: ColumnWriter
      Add a vector page to the file.
      Specified by:
      addVectorPage in interface ColumnWriter
      Throws:
      IOException

    • writePageV2

      public void writePageV2(int rowCount, int nullCount, int valueCount, org.apache.parquet.bytes.BytesInput repetitionLevels, org.apache.parquet.bytes.BytesInput definitionLevels, ByteBuffer data) throws IOException
      Throws:
      IOException

    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface SafeCloseable

    • getColumn

      public org.apache.parquet.column.ColumnDescriptor getColumn()

    • resetStats

      public void resetStats()
      Description copied from interface: ColumnWriter
      Reset the statistics for this column. This must be called between each row group.
      Specified by:
      resetStats in interface ColumnWriter

    • getStats

      public org.apache.parquet.column.statistics.Statistics<?> getStats()
      Description copied from interface: ColumnWriter
      Return the current statistics.
      Specified by:
      getStats in interface ColumnWriter