| 988 | } |
| 989 | |
| 990 | void CSRNodeGroup::collectPersistentUpdatesInRegion(CSRRegion& region, |
| 991 | const CSRNodeGroupCheckpointState& csrState) const { |
| 992 | const auto* txn = csrState.transaction ? csrState.transaction : &DUMMY_CHECKPOINT_TRANSACTION; |
| 993 | const auto leftCSROffset = csrState.oldHeader->getStartCSROffset(region.leftNodeOffset); |
| 994 | const auto rightCSROffset = csrState.oldHeader->getEndCSROffset(region.rightNodeOffset); |
| 995 | region.hasUpdates.resize(csrState.columnIDs.size(), false); |
| 996 | for (auto i = 0u; i < csrState.columnIDs.size(); i++) { |
| 997 | auto columnID = csrState.columnIDs[i]; |
| 998 | if (persistentChunkGroup->hasAnyUpdates(txn, columnID, leftCSROffset, |
| 999 | rightCSROffset - leftCSROffset + 1)) { |
| 1000 | region.hasUpdates[i] = true; |
| 1001 | } |
| 1002 | } |
| 1003 | } |
| 1004 | |
| 1005 | row_idx_t CSRNodeGroup::getNumDeletionsForNodeInPersistentData(offset_t nodeOffset, |
| 1006 | const CSRNodeGroupCheckpointState& csrState) const { |
nothing calls this directly
no test coverage detected