Class foreign_storage::ParquetVariableLengthArrayEncoder¶

class ParquetVariableLengthArrayEncoder : public foreign_storage::ParquetArrayEncoder ¶

Public Functions

ParquetVariableLengthArrayEncoder(Data_Namespace::AbstractBuffer *data_buffer, Data_Namespace::AbstractBuffer *index_buffer, std::shared_ptr<ParquetScalarEncoder> scalar_encoder, const ColumnDescriptor *column_desciptor)¶

void appendData(const int16_t *def_levels, const int16_t *rep_levels, const int64_t values_read, const int64_t levels_read, int8_t *values)¶

Protected Functions

void appendArraysToBuffer()¶

void processLastArray()¶

Private Functions

void setFirstOffsetForBuffer(const int16_t def_level)¶

void appendLastArrayOffset()¶

Private Members

Data_Namespace::AbstractBuffer *index_buffer_¶

std::vector<ArrayOffsetT> offsets_¶