Struct UpdelRoll

struct UpdelRoll

Public Functions

~UpdelRoll()

void cancelUpdate()

bool commitUpdate()

void stageUpdate()

void addDirtyChunk(std::shared_ptr<Chunk_NS::Chunk> chunk, int fragment_id)

std::shared_ptr<ChunkMetadata> getChunkMetadata(const MetaDataKey &key, int32_t column_id, Fragmenter_Namespace::FragmentInfo &fragment_info)

ChunkMetadataMap getChunkMetadataMap(const MetaDataKey &key) const

size_t getNumTuple(const MetaDataKey &key) const

void setNumTuple(const MetaDataKey &key, size_t num_tuple)

Public Members

const Catalog_Namespace::Catalog *catalog = nullptr

int logicalTableId

Data_Namespace::MemoryLevel memoryLevel = {Data_Namespace::MemoryLevel::CPU_LEVEL}

bool is_varlen_update = false

const TableDescriptor *table_descriptor = {nullptr}

Private Functions

void updateFragmenterAndCleanupChunks()

void initializeUnsetMetadata(const TableDescriptor *td, Fragmenter_Namespace::FragmentInfo &fragment_info)

Private Members

mapd_shared_mutex chunk_update_tracker_mutex

std::map<ChunkKey, std::shared_ptr<Chunk_NS::Chunk>> dirty_chunks

std::map<MetaDataKey, size_t> num_tuples

std::map<MetaDataKey, ChunkMetadataMap> chunk_metadata_map_per_fragment