Class foreign_storage::ParquetRowGroupReader¶

class ParquetRowGroupReader¶

Public Functions

ParquetRowGroupReader(std::shared_ptr<parquet::ColumnReader> col_reader, const ColumnDescriptor *column_descriptor, const parquet::ColumnDescriptor *parquet_column_descriptor, ParquetEncoder *encoder, InvalidRowGroupIndices &invalid_indices, const int row_group_index, const int parquet_column_index, const parquet::ParquetFileReader *parquet_reader)¶

void readAndValidateRowGroup()¶

void eraseInvalidRowGroupData(const InvalidRowGroupIndices &invalid_indices)¶

Private Members

std::shared_ptr<parquet::ColumnReader> col_reader_¶

const ColumnDescriptor *column_descriptor_¶

const parquet::ColumnDescriptor *parquet_column_descriptor_¶

ParquetEncoder *encoder_¶

ParquetImportEncoder *import_encoder¶

InvalidRowGroupIndices &invalid_indices_¶

const int row_group_index_¶

const int parquet_column_index_¶

const parquet::ParquetFileReader *parquet_reader_¶