Merge utilization from 'other' into this.
| 248 | |
| 249 | /// Merge utilization from 'other' into this. |
| 250 | void Merge(const ResourceUtilization& other) { |
| 251 | peak_per_host_mem_consumption = |
| 252 | std::max(peak_per_host_mem_consumption, other.peak_per_host_mem_consumption); |
| 253 | total_peak_mem_usage += other.peak_per_host_mem_consumption; |
| 254 | bytes_read += other.bytes_read; |
| 255 | exchange_bytes_sent += other.exchange_bytes_sent; |
| 256 | scan_bytes_sent += other.scan_bytes_sent; |
| 257 | cpu_user_ns += other.cpu_user_ns; |
| 258 | cpu_sys_ns += other.cpu_sys_ns; |
| 259 | MergeMapValues(other.per_join_rows_produced, &per_join_rows_produced); |
| 260 | } |
| 261 | |
| 262 | /// Max join rows produced across join nodes |
| 263 | const std::pair<int32_t, int64_t> MaxJoinNodeRowsProduced() const { |