Package io.deephaven.parquet.base

Class AbstractBulkValuesWriter<BUFFER_TYPE>

java.lang.Object
org.apache.parquet.column.values.ValuesWriter
io.deephaven.parquet.base.AbstractBulkValuesWriter<BUFFER_TYPE>
Type Parameters:
BUFFER_TYPE -
All Implemented Interfaces:
BulkWriter<BUFFER_TYPE>
Direct Known Subclasses:
PlainBinaryChunkedWriter, PlainBooleanChunkedWriter, PlainDoubleChunkedWriter, PlainFloatChunkedWriter, PlainIntChunkedWriter, PlainLongChunkedWriter, RleIntChunkedWriter
public abstract class AbstractBulkValuesWriter<BUFFER_TYPE> extends org.apache.parquet.column.values.ValuesWriter implements BulkWriter<BUFFER_TYPE>
The base class for writing vectors into individual pages.

  • Nested Class Summary

    Nested classes/interfaces inherited from interface io.deephaven.parquet.base.BulkWriter

    BulkWriter.WriteResult

  • Constructor Summary

    Constructors
    Constructor
    Description
    AbstractBulkValuesWriter()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    int
    writeBulkVector(BUFFER_TYPE bulkValues, @NotNull IntBuffer vectorSizes, @NotNull org.apache.parquet.column.values.rle.RunLengthBitPackingHybridEncoder rlEncoder, @NotNull org.apache.parquet.column.values.rle.RunLengthBitPackingHybridEncoder dlEncoder, int nonNullValueCount, @NotNull org.apache.parquet.column.statistics.Statistics<?> statistics)
    Write a buffer's worth of packed vector values to the underlying page.

    Methods inherited from class org.apache.parquet.column.values.ValuesWriter

    close, getAllocatedSize, getBufferedSize, getBytes, getEncoding, memUsageString, reset, resetDictionary, toDictPageAndClose, writeBoolean, writeByte, writeBytes, writeDouble, writeFloat, writeInteger, writeLong

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface io.deephaven.parquet.base.BulkWriter

    getByteBufferView, reset, writeBulk, writeBulkFilterNulls, writeBulkVectorFilterNulls

  • Constructor Details

    • AbstractBulkValuesWriter

      public AbstractBulkValuesWriter()

  • Method Details

    • writeBulkVector

      public int writeBulkVector(@NotNull BUFFER_TYPE bulkValues, @NotNull @NotNull IntBuffer vectorSizes, @NotNull @NotNull org.apache.parquet.column.values.rle.RunLengthBitPackingHybridEncoder rlEncoder, @NotNull @NotNull org.apache.parquet.column.values.rle.RunLengthBitPackingHybridEncoder dlEncoder, int nonNullValueCount, @NotNull @NotNull org.apache.parquet.column.statistics.Statistics<?> statistics) throws IOException
      Description copied from interface: BulkWriter
      Write a buffer's worth of packed vector values to the underlying page. This method will set the proper definition level and repetition values in the encoders for null values.
      Specified by:
      writeBulkVector in interface BulkWriter<BUFFER_TYPE>
      Parameters:
      bulkValues - the packed array values
      vectorSizes - a buffer where each element contains the number of elements in each packed vector.
      rlEncoder - the repetition level encoder
      dlEncoder - the definition level encoder.
      nonNullValueCount - the total count of non-null values
      Returns:
      the number of values actually written
      Throws:
      IOException - if writing failed.