Method flushInternal

src/storage/table/chunked_node_group.cpp:441–465

}

std::unique_ptr<ColumnChunk> InMemChunkedNodeGroup::flushInternal(ColumnChunkData& chunk,
    PageAllocator& pageAllocator) {
    // Finalize is necessary prior to splitting for strings and lists so that pruned values
    // don't have an impact on the number/size of segments It should not be necessary after
    // splitting since the function is used to prune unused values (or duplicated dictionary
    // entries in the case of strings) and those will never be introduced when splitting.
    chunk.finalize();
    if (chunk.shouldSplit()) {
        auto splitSegments = chunk.split(true /*new segments are always the max size if possible*/);
        std::vector<std::unique_ptr<ColumnChunkData>> flushedSegments;
        flushedSegments.reserve(splitSegments.size());
        for (auto& segment : splitSegments) {
            // TODO(bmwinger): This should be removed when splitting works predictively instead of
            // backtracking if we copy too many values
            // It's only needed to prune values from string/list chunks which were truncated
            segment->finalize();
            flushedSegments.push_back(Column::flushChunkData(*segment, pageAllocator));
        }
        return std::make_unique<ColumnChunk>(chunk.isCompressionEnabled(),
            std::move(flushedSegments));
    } else {
        return std::make_unique<ColumnChunk>(chunk.isCompressionEnabled(),
            Column::flushChunkData(chunk, pageAllocator));
    }
}

std::unique_ptr<ChunkedNodeGroup> InMemChunkedNodeGroup::flush(const Transaction* transaction,
    PageAllocator& pageAllocator) {