Class foreign_storage::ParquetGeospatialImportEncoder¶

class ParquetGeospatialImportEncoder : public foreign_storage::ParquetEncoder, public foreign_storage::GeospatialEncoder, public foreign_storage::ParquetImportEncoder ¶

Public Functions

ParquetGeospatialImportEncoder()¶

ParquetGeospatialImportEncoder(std::list<Chunk_NS::Chunk> &chunks)¶

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)¶

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)¶

Private Functions

void appendArrayDatumsIfApplicable(TypedParquetStorageBuffer<ArrayDatum> *column_buffer, const std::vector<ArrayDatum> &datum_buffer)¶

void appendArrayDatumsToBuffer()¶

void appendBaseAndRenderGroupData(const int64_t row_count)¶

AbstractBuffer *getBuffer(std::list<Chunk_NS::Chunk> &chunks, const SQLTypes sql_type, GeoColumnType geo_column_type)¶

Private Members

int64_t current_batch_offset_¶

InvalidRowGroupIndices *invalid_indices_¶

TypedParquetStorageBuffer<std::string> *base_column_buffer_¶

TypedParquetStorageBuffer<ArrayDatum> *coords_column_buffer_¶

TypedParquetStorageBuffer<ArrayDatum> *bounds_column_buffer_¶

TypedParquetStorageBuffer<ArrayDatum> *ring_sizes_column_buffer_¶

TypedParquetStorageBuffer<ArrayDatum> *poly_rings_column_buffer_¶

AbstractBuffer *render_group_column_buffer_¶