Function updateStatistics

src/Interpreters/ConcurrentHashJoin.cpp:75–91

using BlockHashes = std::vector<UInt64>;

void updateStatistics(const auto & hash_joins, const DB::StatsCollectingParams & params)
{
    if (!params.isCollectionAndUseEnabled())
        return;

    const auto ht_size = hash_joins.at(0)->data->getTotalRowCount();
    if (!std::ranges::all_of(hash_joins, [&](const auto & hash_join) { return hash_join->data->getTotalRowCount() == ht_size; }))
        throw DB::Exception(DB::ErrorCodes::LOGICAL_ERROR, "HashJoin instances have different sizes");

    const auto source_rows = std::accumulate(
        hash_joins.begin(),
        hash_joins.end(),
        0ull,
        [](auto acc, const auto & hash_join) { return acc + hash_join->data->getJoinedData()->rows_to_join; });
    if (ht_size)
        DB::getHashTablesStatistics<DB::HashJoinEntry>().update({.ht_size = ht_size, .source_rows = source_rows}, params);
}

UInt32 toPowerOfTwo(UInt32 x)
{