| 396 | } |
| 397 | |
| 398 | void HashAggregation::recordRuntimeMetrics() { |
| 399 | if (groupingSet_ != nullptr && groupingSet_->hasSpilled()) { |
| 400 | this->setRuntimeMetric( |
| 401 | OperatorMetricKey::kTotalRowCount, |
| 402 | folly::to<std::string>(groupingSet_->totalSpillRowCount())); |
| 403 | this->setRuntimeMetric( |
| 404 | OperatorMetricKey::kHasBeenProcessedRowCount, |
| 405 | folly::to<std::string>(groupingSet_->outputSpillRowCount())); |
| 406 | return; |
| 407 | } |
| 408 | this->setRuntimeMetric( |
| 409 | OperatorMetricKey::kTotalRowCount, |
| 410 | folly::to<std::string>(groupingSet_->numDistinct())); |
| 411 | this->setRuntimeMetric( |
| 412 | OperatorMetricKey::kHasBeenProcessedRowCount, |
| 413 | folly::to<std::string>(numOutputRows_)); |
| 414 | } |
| 415 | |
| 416 | void HashAggregation::prepareOutput( |
| 417 | vector_size_t size, |
nothing calls this directly
no test coverage detected