This is an automated email from the ASF dual-hosted git repository.
w41ter pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new c436e9224ad [chore](cloud) expose
split_tablet_stats_into_load_and_compact_parts (#57009)
c436e9224ad is described below
commit c436e9224ad8b2c74723cff171b271ca0b718976
Author: walter <[email protected]>
AuthorDate: Thu Oct 16 12:26:29 2025 +0800
[chore](cloud) expose split_tablet_stats_into_load_and_compact_parts
(#57009)
---
cloud/src/meta-service/meta_service_job.cpp | 23 ----------------------
.../src/meta-service/meta_service_tablet_stats.cpp | 23 ++++++++++++++++++++++
cloud/src/meta-service/meta_service_tablet_stats.h | 3 +++
3 files changed, 26 insertions(+), 23 deletions(-)
diff --git a/cloud/src/meta-service/meta_service_job.cpp
b/cloud/src/meta-service/meta_service_job.cpp
index 14021239785..3e9d73398fb 100644
--- a/cloud/src/meta-service/meta_service_job.cpp
+++ b/cloud/src/meta-service/meta_service_job.cpp
@@ -1357,29 +1357,6 @@ void schema_change_update_tablet_stats(const
TabletSchemaChangeJobPB& schema_cha
segment_size_remove_rowsets));
}
-std::pair<TabletStatsPB, TabletStatsPB>
split_tablet_stats_into_load_and_compact_parts(
- const TabletStatsPB& stats) {
- TabletStatsPB load_stats, compact_stats;
- compact_stats.set_base_compaction_cnt(stats.base_compaction_cnt());
-
compact_stats.set_cumulative_compaction_cnt(stats.cumulative_compaction_cnt());
- compact_stats.set_cumulative_point(stats.cumulative_point());
-
compact_stats.set_last_base_compaction_time_ms(stats.last_base_compaction_time_ms());
-
compact_stats.set_last_cumu_compaction_time_ms(stats.last_cumu_compaction_time_ms());
- compact_stats.set_full_compaction_cnt(stats.full_compaction_cnt());
-
compact_stats.set_last_full_compaction_time_ms(stats.last_full_compaction_time_ms());
- compact_stats.mutable_idx()->CopyFrom(stats.idx());
-
- load_stats.set_num_rows(stats.num_rows());
- load_stats.set_num_rowsets(stats.num_rowsets());
- load_stats.set_num_segments(stats.num_segments());
- load_stats.set_data_size(stats.data_size());
- load_stats.set_index_size(stats.index_size());
- load_stats.set_segment_size(stats.segment_size());
- load_stats.mutable_idx()->CopyFrom(stats.idx());
-
- return {load_stats, compact_stats};
-}
-
std::pair<MetaServiceCode, std::string> scan_schema_change_input_rowsets(
Transaction* txn, std::string_view instance_id, int64_t new_tablet_id,
std::string& rs_start, std::string& rs_end, auto&& callback) {
diff --git a/cloud/src/meta-service/meta_service_tablet_stats.cpp
b/cloud/src/meta-service/meta_service_tablet_stats.cpp
index d35cde07953..2b3c776359e 100644
--- a/cloud/src/meta-service/meta_service_tablet_stats.cpp
+++ b/cloud/src/meta-service/meta_service_tablet_stats.cpp
@@ -537,4 +537,27 @@ MetaServiceResponseStatus check_new_tablet_stats(
return st;
}
+std::pair<TabletStatsPB, TabletStatsPB>
split_tablet_stats_into_load_and_compact_parts(
+ const TabletStatsPB& stats) {
+ TabletStatsPB load_stats, compact_stats;
+ compact_stats.set_base_compaction_cnt(stats.base_compaction_cnt());
+
compact_stats.set_cumulative_compaction_cnt(stats.cumulative_compaction_cnt());
+ compact_stats.set_cumulative_point(stats.cumulative_point());
+
compact_stats.set_last_base_compaction_time_ms(stats.last_base_compaction_time_ms());
+
compact_stats.set_last_cumu_compaction_time_ms(stats.last_cumu_compaction_time_ms());
+ compact_stats.set_full_compaction_cnt(stats.full_compaction_cnt());
+
compact_stats.set_last_full_compaction_time_ms(stats.last_full_compaction_time_ms());
+ compact_stats.mutable_idx()->CopyFrom(stats.idx());
+
+ load_stats.set_num_rows(stats.num_rows());
+ load_stats.set_num_rowsets(stats.num_rowsets());
+ load_stats.set_num_segments(stats.num_segments());
+ load_stats.set_data_size(stats.data_size());
+ load_stats.set_index_size(stats.index_size());
+ load_stats.set_segment_size(stats.segment_size());
+ load_stats.mutable_idx()->CopyFrom(stats.idx());
+
+ return {load_stats, compact_stats};
+}
+
} // namespace doris::cloud
diff --git a/cloud/src/meta-service/meta_service_tablet_stats.h
b/cloud/src/meta-service/meta_service_tablet_stats.h
index 413b998d24e..83b317fd4fb 100644
--- a/cloud/src/meta-service/meta_service_tablet_stats.h
+++ b/cloud/src/meta-service/meta_service_tablet_stats.h
@@ -92,4 +92,7 @@ MetaServiceResponseStatus check_new_tablet_stats(
std::shared_ptr<TxnKv> txn_kv, const std::string& instance_id,
const std::vector<std::shared_ptr<TabletStatsPB>>&
tablet_stat_shared_ptr_vec_batch);
+std::pair<TabletStatsPB, TabletStatsPB>
split_tablet_stats_into_load_and_compact_parts(
+ const TabletStatsPB& stats);
+
} // namespace doris::cloud
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
