| 451 | } |
| 452 | |
| 453 | size_t ConcurrentHashJoin::getTotalRowCount() const |
| 454 | { |
| 455 | size_t res = 0; |
| 456 | for (const auto & hash_join : hash_joins) |
| 457 | { |
| 458 | std::lock_guard lock(hash_join->mutex); |
| 459 | res += hash_join->data->getTotalRowCount(); |
| 460 | } |
| 461 | return res; |
| 462 | } |
| 463 | |
| 464 | size_t ConcurrentHashJoin::getTotalByteCount() const |
| 465 | { |