Function fillCSRGaps

src/storage/table/csr_node_group.cpp:798–827

}

static void fillCSRGaps(CheckpointReadCursor& readCursor, CheckpointWriteCursor& writeCursor,
    ColumnChunkData* dummyChunkForNulls, length_t numOldGaps, length_t numGaps) {
    auto numOldGapsRemaining = numOldGaps;
    auto numGapsRemaining = numGaps;
    if (readCursor.getCSROffset() < writeCursor.getCSROffset()) {
        // Try to advance read cursor to write cursor (if num old gaps is large enough)
        const auto numGapsToAdvance =
            std::min(numOldGapsRemaining, writeCursor.getCSROffset() - readCursor.getCSROffset());
        readCursor.advance(numGapsToAdvance);
        numOldGapsRemaining -= numGapsToAdvance;
    }

    // We can skip writes for any new gaps whose CSR offset also corresponds to an old gap
    if (readCursor.getCSROffset() == writeCursor.getCSROffset()) {
        auto numSkippableGaps = std::min(numGapsRemaining, numOldGapsRemaining);
        numGapsRemaining -= numSkippableGaps;
        writeCursor.advance(numSkippableGaps);
    }

    while (numGapsRemaining > 0) {
        const auto numGapsToFill =
            std::min(numGapsRemaining, static_cast<length_t>(DEFAULT_VECTOR_CAPACITY));
        dummyChunkForNulls->setNumValues(numGapsToFill);
        writeCursor.appendToCurrentSegment(dummyChunkForNulls, 0, numGapsToFill);
        writeCursor.advance(numGapsToFill);
        numGapsRemaining -= numGapsToFill;
    }

    readCursor.advance(numOldGapsRemaining);
}

std::vector<ChunkCheckpointState> CSRNodeGroup::checkpointColumnInRegion(const UniqLock& lock,
    column_id_t columnID, const CSRNodeGroupCheckpointState& csrState,