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_