| 1022 | num_instances_(num_instances) {} |
| 1023 | |
| 1024 | void Coordinator::FragmentStats::AddSplitStats() { |
| 1025 | // These strings are not included in the transposed profile because we have counters. |
| 1026 | if (FLAGS_gen_experimental_profile) return; |
| 1027 | double min = accumulators::min(bytes_assigned_); |
| 1028 | double max = accumulators::max(bytes_assigned_); |
| 1029 | double mean = accumulators::mean(bytes_assigned_); |
| 1030 | double stddev = sqrt(accumulators::variance(bytes_assigned_)); |
| 1031 | stringstream ss; |
| 1032 | ss << " min: " << PrettyPrinter::Print(min, TUnit::BYTES) |
| 1033 | << ", max: " << PrettyPrinter::Print(max, TUnit::BYTES) |
| 1034 | << ", avg: " << PrettyPrinter::Print(mean, TUnit::BYTES) |
| 1035 | << ", stddev: " << PrettyPrinter::Print(stddev, TUnit::BYTES); |
| 1036 | agg_profile_->AddInfoString("split sizes", ss.str()); |
| 1037 | } |
| 1038 | |
| 1039 | void Coordinator::FragmentStats::AddExecStats() { |
| 1040 | root_profile_->SortChildrenByTotalTime(); |
no test coverage detected