lbug 0.16.1

An in-process property graph database management system built for query speed and scalability
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47

#include "storage/table/lazy_segment_scanner.h"

namespace lbug::storage {
void LazySegmentScanner::Iterator::advance(common::offset_t n) {
    segmentScanner.rangeSegments(*this, n,
        [this](auto& segmentData, auto, auto lengthInSegment, auto) {
            DASSERT(segmentData.length > offsetInSegment);
            if (segmentData.length - offsetInSegment == lengthInSegment) {
                ++segmentIdx;
                offsetInSegment = 0;
            } else {
                offsetInSegment += lengthInSegment;
            }
        });
}

void LazySegmentScanner::scanSegment(common::offset_t offsetInSegment,
    common::offset_t segmentLength, scan_func_t newScanFunc) {
    segments.emplace_back(nullptr, offsetInSegment, segmentLength, std::move(newScanFunc));
    numValues += segmentLength;
}

void LazySegmentScanner::applyCommittedUpdates(const UpdateInfo& updateInfo,
    const transaction::Transaction* transaction, common::offset_t startRow,
    common::offset_t numRows) {
    DASSERT(numRows == numValues);
    rangeSegments(begin(), numRows,
        [&](auto& segment, common::offset_t, common::offset_t lengthInSegment,
            common::offset_t offsetInChunk) {
            updateInfo.iterateScan(transaction, startRow + offsetInChunk, lengthInSegment, 0,
                [&](const VectorUpdateInfo& vecUpdateInfo, uint64_t i,
                    uint64_t posInOutput) -> void {
                    scanSegmentIfNeeded(segment);
                    segment.segmentData->write(vecUpdateInfo.data.get(), i, posInOutput, 1);
                });
        });
}

void LazySegmentScanner::scanSegmentIfNeeded(LazySegmentData& segment) {
    if (segment.segmentData == nullptr) {
        segment.segmentData = ColumnChunkFactory::createColumnChunkData(mm, columnType.copy(),
            enableCompression, segment.length, ResidencyState::IN_MEMORY);

        segment.scanFunc(*segment.segmentData, segment.startOffsetInSegment, segment.length);
    }
}
} // namespace lbug::storage