update

Author: Gabriel39

be/src/runtime/fragment_mgr.cpp

@@ -305,17 +305,6 @@ void ConcurrentContextMap<Key, Value, ValueType>::clear() {
     }
 }
 
-template <typename Key, typename Value, typename ValueType>
-size_t ConcurrentContextMap<Key, Value, ValueType>::num_items() const {
-    size_t n = 0;
-    for (auto& pair : _internal_map) {
-        std::shared_lock lock(*pair.first);
-        auto& map = pair.second;
-        n += map.size();
-    }
-    return n;
-}
-
 FragmentMgr::FragmentMgr(ExecEnv* exec_env)
         : _exec_env(exec_env), _stop_background_threads_latch(1) {
     _entity = DorisMetrics::instance()->metric_registry()->register_entity("FragmentMgr");

be/src/runtime/fragment_mgr.h

@@ -77,7 +77,15 @@ class ConcurrentContextMap {
     void insert(const Key& query_id, std::shared_ptr<ValueType>);
     void clear();
     void erase(const Key& query_id);
-    size_t num_items() const;
+    size_t num_items() const {
+        size_t n = 0;
+        for (auto& pair : _internal_map) {
+            std::shared_lock lock(*pair.first);
+            auto& map = pair.second;
+            n += map.size();
+        }
+        return n;
+    }
     void apply(ApplyFunction&& function) {
         for (auto& pair : _internal_map) {
             // TODO: Now only the cancel worker do the GC the _query_ctx_map. each query must