Class foreign_storage::ParquetStringImportEncoder

class ParquetStringImportEncoder : public foreign_storage::ParquetEncoder, public foreign_storage::ParquetImportEncoder

Public Functions

ParquetStringImportEncoder(Data_Namespace::AbstractBuffer *buffer)

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)

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

void validateAndAppendData(const int16_t *def_levels, const int16_t *rep_levels, const int64_t values_read, const int64_t levels_read, int8_t *values, const SQLTypeInfo &column_type, InvalidRowGroupIndices &invalid_indices)

void eraseInvalidIndicesInBuffer(const InvalidRowGroupIndices &invalid_indices)

Private Members

TypedParquetStorageBuffer<std::string> *string_buffer_