Function countChunkDataPages

src/function/table/disk_size_info.cpp:41–79

};

static uint64_t countChunkDataPages(const ColumnChunkData& chunkData) {
    uint64_t pages = 0;
    auto metadata = chunkData.getResidencyState() == ResidencyState::ON_DISK ?
                        chunkData.getMetadata() :
                        chunkData.getMetadataToFlush();
    pages += metadata.getNumPages();

    if (chunkData.hasNullData()) {
        pages += countChunkDataPages(*chunkData.getNullData());
    }

    auto physicalType = chunkData.getDataType().getPhysicalType();
    switch (physicalType) {
    case PhysicalTypeID::STRUCT: {
        auto& structChunk = chunkData.cast<StructChunkData>();
        for (auto i = 0u; i < structChunk.getNumChildren(); i++) {
            pages += countChunkDataPages(structChunk.getChild(i));
        }
    } break;
    case PhysicalTypeID::STRING:
    case PhysicalTypeID::JSON: {
        auto& stringChunk = chunkData.cast<StringChunkData>();
        pages += countChunkDataPages(*stringChunk.getIndexColumnChunk());
        auto& dictionaryChunk = stringChunk.getDictionaryChunk();
        pages += countChunkDataPages(*dictionaryChunk.getStringDataChunk());
        pages += countChunkDataPages(*dictionaryChunk.getOffsetChunk());
    } break;
    case PhysicalTypeID::ARRAY:
    case PhysicalTypeID::LIST: {
        auto& listChunk = chunkData.cast<ListChunkData>();
        pages += countChunkDataPages(*listChunk.getOffsetColumnChunk());
        pages += countChunkDataPages(*listChunk.getSizeColumnChunk());
        pages += countChunkDataPages(*listChunk.getDataColumnChunk());
    } break;
    default:
        break;
    }
    return pages;
}

static uint64_t countChunkedGroupPages(ChunkedNodeGroup* chunkedGroup) {
    uint64_t pages = 0;