| 65 | } |
| 66 | |
| 67 | void merge(node_group_idx_t nodeGroupIdx, |
| 68 | std::unique_ptr<storage::ColumnChunkData> columnChunkData) { |
| 69 | std::unique_lock lck{mtx}; |
| 70 | DASSERT(cachedColumn->columnChunks.size() > nodeGroupIdx); |
| 71 | cachedColumn->columnChunks[nodeGroupIdx] = std::move(columnChunkData); |
| 72 | ++numNodeGroupsCached; |
| 73 | } |
| 74 | |
| 75 | std::mutex mtx; |
| 76 | storage::NodeTable& table; |