| 423 | } |
| 424 | |
| 425 | void NodeGroup::checkpointDataTypesNoLock(const NodeGroupCheckpointState& state) { |
| 426 | std::vector<LogicalType> checkpointedTypes; |
| 427 | for (auto i = 0u; i < state.columnIDs.size(); i++) { |
| 428 | auto columnID = state.columnIDs[i]; |
| 429 | DASSERT(columnID < dataTypes.size()); |
| 430 | checkpointedTypes.push_back(dataTypes[columnID].copy()); |
| 431 | } |
| 432 | dataTypes = std::move(checkpointedTypes); |
| 433 | } |
| 434 | |
| 435 | void NodeGroup::scanCommittedUpdatesForColumn( |
| 436 | std::vector<ChunkCheckpointState>& chunkCheckpointStates, MemoryManager& memoryManager, |