Lines Matching refs:stat
528 for (auto& stat : ta_[type].stats) { in MakeStatistics() local
529 stat.second.a_key_id = 0; in MakeStatistics()
530 for (auto& record : stat.second.a_key_stats) { in MakeStatistics()
531 record.second.key_id = stat.second.a_key_id; in MakeStatistics()
532 stat.second.a_key_id++; in MakeStatistics()
540 if (stat.second.a_count_stats.find(record.second.access_count) == in MakeStatistics()
541 stat.second.a_count_stats.end()) { in MakeStatistics()
542 stat.second.a_count_stats[record.second.access_count] = 1; in MakeStatistics()
544 stat.second.a_count_stats[record.second.access_count]++; in MakeStatistics()
550 if (stat.second.a_key_size_stats.find(record.first.size()) == in MakeStatistics()
551 stat.second.a_key_size_stats.end()) { in MakeStatistics()
552 stat.second.a_key_size_stats[record.first.size()] = 1; in MakeStatistics()
554 stat.second.a_key_size_stats[record.first.size()]++; in MakeStatistics()
559 s = MakeStatisticCorrelation(stat.second, record.second); in MakeStatistics()
568 s = MakeStatisticKeyStatsOrPrefix(stat.second); in MakeStatistics()
575 if (FLAGS_output_access_count_stats && stat.second.a_count_dist_f) { in MakeStatistics()
576 for (auto& record : stat.second.a_count_stats) { in MakeStatistics()
584 s = stat.second.a_count_dist_f->Append(printout); in MakeStatistics()
595 for (auto& record : stat.second.a_key_size_stats) { in MakeStatistics()
597 if (!get_mid && k_count >= stat.second.a_key_mid) { in MakeStatistics()
598 stat.second.a_key_mid = record.first; in MakeStatistics()
601 if (FLAGS_output_key_distribution && stat.second.a_key_size_f) { in MakeStatistics()
608 s = stat.second.a_key_size_f->Append(printout); in MakeStatistics()
619 for (auto& record : stat.second.a_value_size_stats) { in MakeStatistics()
623 if (!get_mid && v_count >= stat.second.a_count / 2) { in MakeStatistics()
624 stat.second.a_value_mid = (v_begin + v_end) / 2; in MakeStatistics()
627 if (FLAGS_output_value_distribution && stat.second.a_value_size_f && in MakeStatistics()
638 s = stat.second.a_value_size_f->Append(printout); in MakeStatistics()
804 for (auto& stat : ta_[type].stats) { in MakeStatisticQPS() local
807 for (auto& time_it : stat.second.a_qps_stats) { in MakeStatisticQPS()
814 if (time_it.second > stat.second.a_peak_qps) { in MakeStatisticQPS()
815 stat.second.a_peak_qps = time_it.second; in MakeStatisticQPS()
817 if (stat.second.a_qps_f) { in MakeStatisticQPS()
824 s = stat.second.a_qps_f->Append(printout); in MakeStatisticQPS()
836 s = stat.second.a_qps_f->Append(printout); in MakeStatisticQPS()
848 if (static_cast<int32_t>(stat.second.top_k_qps_sec.size()) < in MakeStatisticQPS()
850 stat.second.top_k_qps_sec.push( in MakeStatisticQPS()
853 if (stat.second.top_k_qps_sec.size() > 0 && in MakeStatisticQPS()
854 stat.second.top_k_qps_sec.top().first < time_it.second) { in MakeStatisticQPS()
855 stat.second.top_k_qps_sec.pop(); in MakeStatisticQPS()
856 stat.second.top_k_qps_sec.push( in MakeStatisticQPS()
863 stat.second.a_ave_qps = 0; in MakeStatisticQPS()
865 stat.second.a_ave_qps = (static_cast<double>(cf_qps_sum)) / duration; in MakeStatisticQPS()
869 if (stat.second.a_key_num_f) { in MakeStatisticQPS()
871 static_cast<uint64_t>(stat.second.a_key_stats.size()); in MakeStatisticQPS()
875 auto find_time = stat.second.uni_key_num.find(i); in MakeStatisticQPS()
876 if (find_time != stat.second.uni_key_num.end()) { in MakeStatisticQPS()
886 s = stat.second.a_key_num_f->Append(printout); in MakeStatisticQPS()
896 if (FLAGS_output_prefix_cut > 0 && stat.second.a_top_qps_prefix_f) { in MakeStatisticQPS()
897 while (!stat.second.top_k_qps_sec.empty()) { in MakeStatisticQPS()
899 stat.second.top_k_qps_sec.top().second, in MakeStatisticQPS()
900 stat.second.top_k_qps_sec.top().first); in MakeStatisticQPS()
905 s = stat.second.a_top_qps_prefix_f->Append(printout); in MakeStatisticQPS()
910 uint32_t qps_time = stat.second.top_k_qps_sec.top().second; in MakeStatisticQPS()
911 stat.second.top_k_qps_sec.pop(); in MakeStatisticQPS()
912 if (stat.second.a_qps_prefix_stats.find(qps_time) != in MakeStatisticQPS()
913 stat.second.a_qps_prefix_stats.end()) { in MakeStatisticQPS()
914 for (auto& qps_prefix : stat.second.a_qps_prefix_stats[qps_time]) { in MakeStatisticQPS()
924 s = stat.second.a_top_qps_prefix_f->Append(pout); in MakeStatisticQPS()
1016 TraceStats& stat = ta_[type].stats[cf_id]; in ReProcessing() local
1017 if (!stat.time_series_f) { in ReProcessing()
1022 while (!stat.time_series.empty()) { in ReProcessing()
1024 auto found = stat.a_key_stats.find(stat.time_series.front().key); in ReProcessing()
1025 if (found != stat.a_key_stats.end()) { in ReProcessing()
1030 stat.time_series.front().type, in ReProcessing()
1031 stat.time_series.front().ts, key_id); in ReProcessing()
1036 s = stat.time_series_f->Append(printout); in ReProcessing()
1041 stat.time_series.pop_front(); in ReProcessing()
1083 TraceStats& stat = ta_[type].stats[cf_id]; in ReProcessing() local
1084 if (stat.w_key_f) { in ReProcessing()
1085 if (stat.a_key_stats.find(input_key) != stat.a_key_stats.end()) { in ReProcessing()
1088 stat.a_key_stats[input_key].access_count); in ReProcessing()
1093 s = stat.w_key_f->Append(printout); in ReProcessing()
1102 if (FLAGS_output_prefix_cut > 0 && stat.w_prefix_cut_f) { in ReProcessing()
1114 s = stat.w_prefix_cut_f->Append(printout); in ReProcessing()
1144 TraceStats& stat = ta_[type].stats[cf_id]; in ReProcessing() local
1145 for (auto& record : stat.a_key_stats) { in ReProcessing()
1146 if (static_cast<int32_t>(stat.top_k_queue.size()) < in ReProcessing()
1148 stat.top_k_queue.push( in ReProcessing()
1151 if (record.second.access_count > stat.top_k_queue.top().first) { in ReProcessing()
1152 stat.top_k_queue.pop(); in ReProcessing()
1153 stat.top_k_queue.push( in ReProcessing()
1458 for (auto& stat : ta_[type].stats) { in CloseOutputFiles() local
1459 if (stat.second.time_series_f) { in CloseOutputFiles()
1460 stat.second.time_series_f->Close(); in CloseOutputFiles()
1463 if (stat.second.a_key_f) { in CloseOutputFiles()
1464 stat.second.a_key_f->Close(); in CloseOutputFiles()
1467 if (stat.second.a_key_num_f) { in CloseOutputFiles()
1468 stat.second.a_key_num_f->Close(); in CloseOutputFiles()
1471 if (stat.second.a_count_dist_f) { in CloseOutputFiles()
1472 stat.second.a_count_dist_f->Close(); in CloseOutputFiles()
1475 if (stat.second.a_prefix_cut_f) { in CloseOutputFiles()
1476 stat.second.a_prefix_cut_f->Close(); in CloseOutputFiles()
1479 if (stat.second.a_value_size_f) { in CloseOutputFiles()
1480 stat.second.a_value_size_f->Close(); in CloseOutputFiles()
1483 if (stat.second.a_key_size_f) { in CloseOutputFiles()
1484 stat.second.a_key_size_f->Close(); in CloseOutputFiles()
1487 if (stat.second.a_qps_f) { in CloseOutputFiles()
1488 stat.second.a_qps_f->Close(); in CloseOutputFiles()
1491 if (stat.second.a_top_qps_prefix_f) { in CloseOutputFiles()
1492 stat.second.a_top_qps_prefix_f->Close(); in CloseOutputFiles()
1495 if (stat.second.w_key_f) { in CloseOutputFiles()
1496 stat.second.w_key_f->Close(); in CloseOutputFiles()
1498 if (stat.second.w_prefix_cut_f) { in CloseOutputFiles()
1499 stat.second.w_prefix_cut_f->Close(); in CloseOutputFiles()
1779 TraceStats& stat = stat_it.second; in PrintStatistics() local
1780 uint64_t total_a_keys = static_cast<uint64_t>(stat.a_key_stats.size()); in PrintStatistics()
1785 if (stat.a_count > 0) { in PrintStatistics()
1787 (static_cast<double>(stat.a_key_size_sum)) / stat.a_count; in PrintStatistics()
1789 (static_cast<double>(stat.a_value_size_sum)) / stat.a_count; in PrintStatistics()
1790 key_size_vari = std::sqrt((static_cast<double>(stat.a_key_size_sqsum)) / in PrintStatistics()
1791 stat.a_count - in PrintStatistics()
1794 (static_cast<double>(stat.a_value_size_sqsum)) / stat.a_count - in PrintStatistics()
1798 stat.a_value_mid = 0; in PrintStatistics()
1800 cfs_[stat.cf_id].a_count += total_a_keys; in PrintStatistics()
1802 ta_[type].total_access += stat.a_count; in PrintStatistics()
1803 ta_[type].total_succ_access += stat.a_succ_count; in PrintStatistics()
1805 printf("colume family id: %u\n", stat.cf_id); in PrintStatistics()
1807 ta_[type].type_name.c_str(), stat.a_count); in PrintStatistics()
1811 key_size_ave, stat.a_key_mid, key_size_vari); in PrintStatistics()
1815 value_size_ave, stat.a_value_mid, value_size_vari); in PrintStatistics()
1817 printf("Peak QPS is: %u Average QPS is: %f\n", stat.a_peak_qps, in PrintStatistics()
1818 stat.a_ave_qps); in PrintStatistics()
1824 while (!stat.top_k_queue.empty()) { in PrintStatistics()
1826 stat.top_k_queue.top().second); in PrintStatistics()
1827 printf("Access_count: %" PRIu64 " %s\n", stat.top_k_queue.top().first, in PrintStatistics()
1829 stat.top_k_queue.pop(); in PrintStatistics()
1837 while (!stat.top_k_prefix_access.empty()) { in PrintStatistics()
1839 stat.top_k_prefix_access.top().second.c_str(), in PrintStatistics()
1840 stat.top_k_prefix_access.top().first); in PrintStatistics()
1841 stat.top_k_prefix_access.pop(); in PrintStatistics()
1846 while (!stat.top_k_prefix_ave.empty()) { in PrintStatistics()
1848 stat.top_k_prefix_ave.top().second.c_str(), in PrintStatistics()
1849 stat.top_k_prefix_ave.top().first); in PrintStatistics()
1850 stat.top_k_prefix_ave.pop(); in PrintStatistics()
1867 if (stat.correlation_output[correlation].first > 0) { in PrintStatistics()
1870 stat.correlation_output[correlation].second)) / in PrintStatistics()
1871 (stat.correlation_output[correlation].first * 1000); in PrintStatistics()
1874 stat.correlation_output[correlation].first, correlation_ave); in PrintStatistics()