| 504 | } |
| 505 | |
| 506 | void aggregateOperatorRuntimeStats( |
| 507 | std::unordered_map<std::string, RuntimeMetric>& stats) { |
| 508 | for (auto& runtimeMetric : stats) { |
| 509 | if (shouldAggregateRuntimeMetric(runtimeMetric.first)) { |
| 510 | runtimeMetric.second.aggregate(); |
| 511 | } |
| 512 | } |
| 513 | } |
| 514 | |
| 515 | folly::Range<vector_size_t*> initializeRowNumberMapping( |
| 516 | BufferPtr& mapping, |
no test coverage detected