Coverage Report

Created: 2026-03-20 13:21

next uncovered line (L), next uncovered region (R), next uncovered branch (B)
/root/doris/be/src/runtime/exec_env.h
Line
Count
Source
1
// Licensed to the Apache Software Foundation (ASF) under one
2
// or more contributor license agreements.  See the NOTICE file
3
// distributed with this work for additional information
4
// regarding copyright ownership.  The ASF licenses this file
5
// to you under the Apache License, Version 2.0 (the
6
// "License"); you may not use this file except in compliance
7
// with the License.  You may obtain a copy of the License at
8
//
9
//   http://www.apache.org/licenses/LICENSE-2.0
10
//
11
// Unless required by applicable law or agreed to in writing,
12
// software distributed under the License is distributed on an
13
// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
14
// KIND, either express or implied.  See the License for the
15
// specific language governing permissions and limitations
16
// under the License.
17
18
#pragma once
19
20
#include <common/multi_version.h>
21
#include <gen_cpp/olap_file.pb.h>
22
23
#include <atomic>
24
#include <map>
25
#include <memory>
26
#include <mutex>
27
#include <optional>
28
#include <string>
29
#include <vector>
30
31
#include "common/config.h"
32
#include "common/status.h"
33
#include "exec/schema_scanner/schema_routine_load_job_scanner.h"
34
#include "io/cache/fs_file_cache_storage.h"
35
#include "olap/memtable_memory_limiter.h"
36
#include "olap/options.h"
37
#include "olap/rowset/segment_v2/inverted_index_writer.h"
38
#include "olap/tablet_fwd.h"
39
#include "pipeline/pipeline_tracing.h"
40
#include "runtime/cluster_info.h"
41
#include "runtime/frontend_info.h" // TODO(zhiqiang): find a way to remove this include header
42
#include "util/threadpool.h"
43
44
namespace orc {
45
class MemoryPool;
46
}
47
namespace arrow {
48
class MemoryPool;
49
}
50
51
namespace doris {
52
namespace vectorized {
53
class VDataStreamMgr;
54
class SpillStreamManager;
55
class DeltaWriterV2Pool;
56
class DictionaryFactory;
57
} // namespace vectorized
58
namespace pipeline {
59
class TaskScheduler;
60
struct RuntimeFilterTimerQueue;
61
} // namespace pipeline
62
class WorkloadGroupMgr;
63
struct WriteCooldownMetaExecutors;
64
class S3RateLimiterHolder;
65
namespace io {
66
class FileCacheFactory;
67
class HdfsMgr;
68
class PackedFileManager;
69
} // namespace io
70
namespace segment_v2 {
71
class InvertedIndexSearcherCache;
72
class InvertedIndexQueryCache;
73
class ConditionCache;
74
class TmpFileDirs;
75
class EncodingInfoResolver;
76
77
namespace inverted_index {
78
class AnalysisFactoryMgr;
79
}
80
81
} // namespace segment_v2
82
83
namespace kerberos {
84
class KerberosTicketMgr;
85
}
86
87
class QueryCache;
88
class WorkloadSchedPolicyMgr;
89
class BfdParser;
90
class BrokerMgr;
91
template <class T>
92
class BrpcClientCache;
93
class ExternalScanContextMgr;
94
class FragmentMgr;
95
class ResultCache;
96
class LoadPathMgr;
97
class NewLoadStreamMgr;
98
class MemTrackerLimiter;
99
class MemTracker;
100
struct TrackerLimiterGroup;
101
class BaseStorageEngine;
102
class ResultBufferMgr;
103
class ResultQueueMgr;
104
class RuntimeQueryStatisticsMgr;
105
class LoadChannelMgr;
106
class LoadStreamMgr;
107
class LoadStreamMapPool;
108
class StreamLoadExecutor;
109
class RoutineLoadTaskExecutor;
110
class StreamLoadRecorderManager;
111
class SmallFileMgr;
112
class BackendServiceClient;
113
class TPaloBrokerServiceClient;
114
class PBackendService_Stub;
115
class PFunctionService_Stub;
116
template <class T>
117
class ClientCache;
118
class HeartbeatFlags;
119
class FrontendServiceClient;
120
class FileMetaCache;
121
class GroupCommitMgr;
122
class CdcClientMgr;
123
class TabletSchemaCache;
124
class TabletColumnObjectPool;
125
class UserFunctionCache;
126
class SchemaCache;
127
class StoragePageCache;
128
class SegmentLoader;
129
class LookupConnectionCache;
130
class RowCache;
131
class DummyLRUCache;
132
class CacheManager;
133
class IdManager;
134
class ProcessProfile;
135
class HeapProfiler;
136
class WalManager;
137
class DNSCache;
138
class IndexPolicyMgr;
139
struct SyncRowsetStats;
140
class DeleteBitmapAggCache;
141
142
// set to true when BE is shutting down
143
inline bool k_doris_exit = false;
144
// set to true after BE start ready
145
inline bool k_is_server_ready = false;
146
147
// Execution environment for queries/plan fragments.
148
// Contains all required global structures, and handles to
149
// singleton services. Clients must call StartServices exactly
150
// once to properly initialise service state.
151
class ExecEnv {
152
public:
153
    // Empty destructor because the compiler-generated one requires full
154
    // declarations for classes in scoped_ptrs.
155
    ~ExecEnv();
156
157
8.90k
    BaseStorageEngine& storage_engine() { return *_storage_engine; }
158
159
    // Initial exec environment. must call this to init all
160
    [[nodiscard]] static Status init(ExecEnv* env, const std::vector<StorePath>& store_paths,
161
                                     const std::vector<StorePath>& spill_store_paths,
162
                                     const std::set<std::string>& broken_paths);
163
164
    // Stop all threads and delete resources.
165
    void destroy();
166
167
    /// Returns the first created exec env instance. In a normal doris, this is
168
    /// the only instance. In test setups with multiple ExecEnv's per process,
169
    /// we return the most recently created instance.
170
950k
    static ExecEnv* GetInstance() {
171
950k
        static ExecEnv s_exec_env;
172
950k
        return &s_exec_env;
173
950k
    }
174
175
    // Requires ExenEnv ready
176
    static Result<BaseTabletSPtr> get_tablet(int64_t tablet_id,
177
                                             SyncRowsetStats* sync_stats = nullptr,
178
                                             bool force_use_only_cached = false);
179
180
480k
    static bool ready() { return _s_ready.load(std::memory_order_acquire); }
181
72
    static bool tracking_memory() { return _s_tracking_memory.load(std::memory_order_acquire); }
182
8
    static bool get_is_upgrading() { return _s_upgrading.load(std::memory_order_acquire); }
183
0
    static void set_is_upgrading() { _s_upgrading = true; }
184
    const std::string& token() const;
185
0
    ExternalScanContextMgr* external_scan_context_mgr() { return _external_scan_context_mgr; }
186
8
    vectorized::VDataStreamMgr* vstream_mgr() { return _vstream_mgr; }
187
0
    ResultBufferMgr* result_mgr() { return _result_mgr; }
188
1
    ResultQueueMgr* result_queue_mgr() { return _result_queue_mgr; }
189
0
    ClientCache<BackendServiceClient>* client_cache() { return _backend_client_cache; }
190
0
    ClientCache<FrontendServiceClient>* frontend_client_cache() { return _frontend_client_cache; }
191
0
    ClientCache<TPaloBrokerServiceClient>* broker_client_cache() { return _broker_client_cache; }
192
193
1.74k
    WorkloadGroupMgr* workload_group_mgr() { return _workload_group_manager; }
194
0
    WorkloadSchedPolicyMgr* workload_sched_policy_mgr() { return _workload_sched_mgr; }
195
0
    RuntimeQueryStatisticsMgr* runtime_query_statistics_mgr() {
196
0
        return _runtime_query_statistics_mgr;
197
0
    }
198
199
    // using template to simplify client cache management
200
    template <typename T>
201
    inline ClientCache<T>* get_client_cache() {
202
        return nullptr;
203
    }
204
205
    // Save all MemTrackerLimiters in use.
206
    // Each group corresponds to several MemTrackerLimiters and has a lock.
207
    // Multiple groups are used to reduce the impact of locks.
208
    std::vector<TrackerLimiterGroup> mem_tracker_limiter_pool;
209
    void init_mem_tracker();
210
414k
    std::shared_ptr<MemTrackerLimiter> orphan_mem_tracker() { return _orphan_mem_tracker; }
211
0
    std::shared_ptr<MemTrackerLimiter> brpc_iobuf_block_memory_tracker() {
212
0
        return _brpc_iobuf_block_memory_tracker;
213
0
    }
214
0
    std::shared_ptr<MemTrackerLimiter> segcompaction_mem_tracker() {
215
0
        return _segcompaction_mem_tracker;
216
0
    }
217
8
    std::shared_ptr<MemTrackerLimiter> stream_load_pipe_tracker() {
218
8
        return _stream_load_pipe_tracker;
219
8
    }
220
0
    std::shared_ptr<MemTrackerLimiter> tablets_no_cache_mem_tracker() {
221
0
        return _tablets_no_cache_mem_tracker;
222
0
    }
223
0
    std::shared_ptr<MemTrackerLimiter> rowsets_no_cache_mem_tracker() {
224
0
        return _rowsets_no_cache_mem_tracker;
225
0
    }
226
0
    std::shared_ptr<MemTrackerLimiter> segments_no_cache_mem_tracker() {
227
0
        return _segments_no_cache_mem_tracker;
228
0
    }
229
2.09k
    std::shared_ptr<MemTrackerLimiter> point_query_executor_mem_tracker() {
230
2.09k
        return _point_query_executor_mem_tracker;
231
2.09k
    }
232
12
    std::shared_ptr<MemTrackerLimiter> query_cache_mem_tracker() {
233
12
        return _query_cache_mem_tracker;
234
12
    }
235
26.3k
    std::shared_ptr<MemTrackerLimiter> block_compression_mem_tracker() {
236
26.3k
        return _block_compression_mem_tracker;
237
26.3k
    }
238
0
    std::shared_ptr<MemTrackerLimiter> rowid_storage_reader_tracker() {
239
0
        return _rowid_storage_reader_tracker;
240
0
    }
241
2.15k
    std::shared_ptr<MemTrackerLimiter> subcolumns_tree_tracker() {
242
2.15k
        return _subcolumns_tree_tracker;
243
2.15k
    }
244
2.83k
    std::shared_ptr<MemTrackerLimiter> s3_file_buffer_tracker() { return _s3_file_buffer_tracker; }
245
192
    std::shared_ptr<MemTrackerLimiter> parquet_meta_tracker() { return _parquet_meta_tracker; }
246
247
0
    ThreadPool* send_batch_thread_pool() { return _send_batch_thread_pool.get(); }
248
4
    ThreadPool* buffered_reader_prefetch_thread_pool() {
249
4
        return _buffered_reader_prefetch_thread_pool.get();
250
4
    }
251
0
    ThreadPool* send_table_stats_thread_pool() { return _send_table_stats_thread_pool.get(); }
252
2.41k
    ThreadPool* s3_file_upload_thread_pool() { return _s3_file_upload_thread_pool.get(); }
253
0
    ThreadPool* lazy_release_obj_pool() { return _lazy_release_obj_pool.get(); }
254
    ThreadPool* non_block_close_thread_pool();
255
0
    ThreadPool* s3_file_system_thread_pool() { return _s3_file_system_thread_pool.get(); }
256
0
    ThreadPool* udf_close_workers_pool() { return _udf_close_workers_thread_pool.get(); }
257
258
    void init_file_cache_factory(std::vector<doris::CachePath>& cache_paths);
259
4.16k
    io::FileCacheFactory* file_cache_factory() { return _file_cache_factory; }
260
0
    UserFunctionCache* user_function_cache() { return _user_function_cache; }
261
121k
    FragmentMgr* fragment_mgr() { return _fragment_mgr; }
262
0
    ResultCache* result_cache() { return _result_cache; }
263
14
    ClusterInfo* cluster_info() { return _cluster_info; }
264
1
    LoadPathMgr* load_path_mgr() { return _load_path_mgr; }
265
1
    BfdParser* bfd_parser() const { return _bfd_parser; }
266
0
    BrokerMgr* broker_mgr() const { return _broker_mgr; }
267
0
    BrpcClientCache<PBackendService_Stub>* brpc_internal_client_cache() const {
268
0
        return _internal_client_cache;
269
0
    }
270
0
    BrpcClientCache<PBackendService_Stub>* brpc_streaming_client_cache() const {
271
0
        return _streaming_client_cache;
272
0
    }
273
0
    BrpcClientCache<PFunctionService_Stub>* brpc_function_client_cache() const {
274
0
        return _function_client_cache;
275
0
    }
276
0
    LoadChannelMgr* load_channel_mgr() { return _load_channel_mgr; }
277
0
    LoadStreamMgr* load_stream_mgr() { return _load_stream_mgr.get(); }
278
3
    NewLoadStreamMgr* new_load_stream_mgr() { return _new_load_stream_mgr.get(); }
279
0
    SmallFileMgr* small_file_mgr() { return _small_file_mgr; }
280
621
    doris::vectorized::SpillStreamManager* spill_stream_mgr() { return _spill_stream_mgr; }
281
0
    GroupCommitMgr* group_commit_mgr() { return _group_commit_mgr; }
282
0
    CdcClientMgr* cdc_client_mgr() { return _cdc_client_mgr; }
283
284
3
    const std::vector<StorePath>& store_paths() const { return _store_paths; }
285
286
1
    StreamLoadExecutor* stream_load_executor() { return _stream_load_executor.get(); }
287
0
    RoutineLoadTaskExecutor* routine_load_task_executor() { return _routine_load_task_executor; }
288
0
    HeartbeatFlags* heartbeat_flags() { return _heartbeat_flags; }
289
14
    FileMetaCache* file_meta_cache() { return _file_meta_cache; }
290
16
    MemTableMemoryLimiter* memtable_memory_limiter() { return _memtable_memory_limiter.get(); }
291
47
    WalManager* wal_mgr() { return _wal_manager.get(); }
292
8
    DNSCache* dns_cache() { return _dns_cache; }
293
5
    WriteCooldownMetaExecutors* write_cooldown_meta_executors() {
294
5
        return _write_cooldown_meta_executors.get();
295
5
    }
296
297
0
    kerberos::KerberosTicketMgr* kerberos_ticket_mgr() { return _kerberos_ticket_mgr; }
298
0
    io::HdfsMgr* hdfs_mgr() { return _hdfs_mgr; }
299
0
    io::PackedFileManager* packed_file_manager() { return _packed_file_manager; }
300
3
    IndexPolicyMgr* index_policy_mgr() { return _index_policy_mgr; }
301
0
    S3RateLimiterHolder* warmup_download_rate_limiter() { return _warmup_download_rate_limiter; }
302
303
#ifdef BE_TEST
304
223
    void set_tmp_file_dir(std::unique_ptr<segment_v2::TmpFileDirs> tmp_file_dirs) {
305
223
        this->_tmp_file_dirs = std::move(tmp_file_dirs);
306
223
    }
307
4
    void set_ready() { this->_s_ready = true; }
308
0
    void set_not_ready() { this->_s_ready = false; }
309
36
    void set_memtable_memory_limiter(MemTableMemoryLimiter* limiter) {
310
36
        _memtable_memory_limiter.reset(limiter);
311
36
    }
312
59
    void set_cluster_info(ClusterInfo* cluster_info) { this->_cluster_info = cluster_info; }
313
    void set_new_load_stream_mgr(std::unique_ptr<NewLoadStreamMgr>&& new_load_stream_mgr);
314
    void clear_new_load_stream_mgr();
315
    void set_stream_load_executor(std::unique_ptr<StreamLoadExecutor>&& stream_load_executor);
316
    void clear_stream_load_executor();
317
318
    void set_storage_engine(std::unique_ptr<BaseStorageEngine>&& engine);
319
    void set_inverted_index_searcher_cache(
320
            segment_v2::InvertedIndexSearcherCache* inverted_index_searcher_cache);
321
    void set_inverted_index_query_cache(
322
0
            segment_v2::InvertedIndexQueryCache* inverted_index_query_cache) {
323
0
        _inverted_index_query_cache = inverted_index_query_cache;
324
0
    }
325
1
    void set_cache_manager(CacheManager* cm) { this->_cache_manager = cm; }
326
1
    void set_process_profile(ProcessProfile* pp) { this->_process_profile = pp; }
327
1
    void set_tablet_schema_cache(TabletSchemaCache* c) { this->_tablet_schema_cache = c; }
328
1
    void set_delete_bitmap_agg_cache(DeleteBitmapAggCache* c) { _delete_bitmap_agg_cache = c; }
329
1
    void set_tablet_column_object_pool(TabletColumnObjectPool* c) {
330
1
        this->_tablet_column_object_pool = c;
331
1
    }
332
1
    void set_storage_page_cache(StoragePageCache* c) { this->_storage_page_cache = c; }
333
1
    void set_segment_loader(SegmentLoader* sl) { this->_segment_loader = sl; }
334
0
    void set_routine_load_task_executor(RoutineLoadTaskExecutor* r) {
335
0
        this->_routine_load_task_executor = r;
336
0
    }
337
    void set_wal_mgr(std::unique_ptr<WalManager>&& wm);
338
    void clear_wal_mgr();
339
340
    void set_write_cooldown_meta_executors();
341
1
    static void set_tracking_memory(bool tracking_memory) {
342
1
        _s_tracking_memory.store(tracking_memory, std::memory_order_release);
343
1
    }
344
1
    void set_orc_memory_pool(orc::MemoryPool* pool) { _orc_memory_pool = pool; }
345
2
    void set_non_block_close_thread_pool(std::unique_ptr<ThreadPool>&& pool) {
346
2
        _non_block_close_thread_pool = std::move(pool);
347
2
    }
348
2
    void set_s3_file_upload_thread_pool(std::unique_ptr<ThreadPool>&& pool) {
349
2
        _s3_file_upload_thread_pool = std::move(pool);
350
2
    }
351
0
    void set_file_cache_factory(io::FileCacheFactory* factory) { _file_cache_factory = factory; }
352
2
    void set_file_cache_open_fd_cache(std::unique_ptr<io::FDCache>&& fd_cache) {
353
2
        _file_cache_open_fd_cache = std::move(fd_cache);
354
2
    }
355
#endif
356
0
    LoadStreamMapPool* load_stream_map_pool() { return _load_stream_map_pool.get(); }
357
358
0
    vectorized::DeltaWriterV2Pool* delta_writer_v2_pool() { return _delta_writer_v2_pool.get(); }
359
360
    void wait_for_all_tasks_done();
361
362
    void update_frontends(const std::vector<TFrontendInfo>& new_infos);
363
    std::vector<TFrontendInfo> get_frontends();
364
    std::map<TNetworkAddress, FrontendInfo> get_running_frontends();
365
366
13.9k
    TabletSchemaCache* get_tablet_schema_cache() { return _tablet_schema_cache; }
367
1.04k
    TabletColumnObjectPool* get_tablet_column_object_pool() { return _tablet_column_object_pool; }
368
0
    SchemaCache* schema_cache() { return _schema_cache; }
369
43.8k
    StoragePageCache* get_storage_page_cache() { return _storage_page_cache; }
370
26.9k
    SegmentLoader* segment_loader() { return _segment_loader; }
371
0
    LookupConnectionCache* get_lookup_connection_cache() { return _lookup_connection_cache; }
372
0
    RowCache* get_row_cache() { return _row_cache; }
373
2.15k
    CacheManager* get_cache_manager() { return _cache_manager; }
374
0
    IdManager* get_id_manager() { return _id_manager; }
375
2
    ProcessProfile* get_process_profile() { return _process_profile; }
376
0
    HeapProfiler* get_heap_profiler() { return _heap_profiler; }
377
271
    segment_v2::InvertedIndexSearcherCache* get_inverted_index_searcher_cache() {
378
271
        return _inverted_index_searcher_cache;
379
271
    }
380
237
    segment_v2::InvertedIndexQueryCache* get_inverted_index_query_cache() {
381
237
        return _inverted_index_query_cache;
382
237
    }
383
0
    segment_v2::EncodingInfoResolver* get_encoding_info_resolver() {
384
0
        return _encoding_info_resolver;
385
0
    }
386
0
    segment_v2::ConditionCache* get_condition_cache() { return _condition_cache; }
387
3
    QueryCache* get_query_cache() { return _query_cache; }
388
389
1
    pipeline::RuntimeFilterTimerQueue* runtime_filter_timer_queue() {
390
1
        return _runtime_filter_timer_queue;
391
1
    }
392
393
2
    vectorized::DictionaryFactory* dict_factory() { return _dict_factory; }
394
395
0
    pipeline::PipelineTracerContext* pipeline_tracer_context() {
396
0
        return _pipeline_tracer_ctx.get();
397
0
    }
398
399
574
    segment_v2::TmpFileDirs* get_tmp_file_dirs() { return _tmp_file_dirs.get(); }
400
19.2k
    io::FDCache* file_cache_open_fd_cache() const { return _file_cache_open_fd_cache.get(); }
401
402
52
    orc::MemoryPool* orc_memory_pool() { return _orc_memory_pool; }
403
0
    arrow::MemoryPool* arrow_memory_pool() { return _arrow_memory_pool; }
404
405
    bool check_auth_token(const std::string& auth_token);
406
3
    void set_stream_mgr(vectorized::VDataStreamMgr* vstream_mgr) { _vstream_mgr = vstream_mgr; }
407
    void clear_stream_mgr();
408
409
190
    DeleteBitmapAggCache* delete_bitmap_agg_cache() { return _delete_bitmap_agg_cache; }
410
    Status init_mem_env();
411
412
private:
413
    ExecEnv();
414
415
    [[nodiscard]] Status _init(const std::vector<StorePath>& store_paths,
416
                               const std::vector<StorePath>& spill_store_paths,
417
                               const std::set<std::string>& broken_paths);
418
    void _destroy();
419
420
    Status _check_deploy_mode();
421
422
    Status _create_internal_workload_group();
423
    void _init_runtime_filter_timer_queue();
424
425
    inline static std::atomic_bool _s_ready {false};
426
    inline static std::atomic_bool _s_tracking_memory {false};
427
    std::vector<StorePath> _store_paths;
428
    std::vector<StorePath> _spill_store_paths;
429
    inline static std::atomic_bool _s_upgrading {false};
430
431
    io::FileCacheFactory* _file_cache_factory = nullptr;
432
    UserFunctionCache* _user_function_cache = nullptr;
433
    // Leave protected so that subclasses can override
434
    ExternalScanContextMgr* _external_scan_context_mgr = nullptr;
435
    vectorized::VDataStreamMgr* _vstream_mgr = nullptr;
436
    ResultBufferMgr* _result_mgr = nullptr;
437
    ResultQueueMgr* _result_queue_mgr = nullptr;
438
    ClientCache<BackendServiceClient>* _backend_client_cache = nullptr;
439
    ClientCache<FrontendServiceClient>* _frontend_client_cache = nullptr;
440
    ClientCache<TPaloBrokerServiceClient>* _broker_client_cache = nullptr;
441
442
    // The default tracker consumed by mem hook. If the thread does not attach other trackers,
443
    // by default all consumption will be passed to the process tracker through the orphan tracker.
444
    // In real time, `consumption of all limiter trackers` + `orphan tracker consumption` = `process tracker consumption`.
445
    // Ideally, all threads are expected to attach to the specified tracker, so that "all memory has its own ownership",
446
    // and the consumption of the orphan mem tracker is close to 0, but greater than 0.
447
    std::shared_ptr<MemTrackerLimiter> _orphan_mem_tracker;
448
    std::shared_ptr<MemTrackerLimiter> _brpc_iobuf_block_memory_tracker;
449
    // Count the memory consumption of segment compaction tasks.
450
    std::shared_ptr<MemTrackerLimiter> _segcompaction_mem_tracker;
451
    std::shared_ptr<MemTrackerLimiter> _stream_load_pipe_tracker;
452
453
    std::shared_ptr<MemTrackerLimiter> _tablets_no_cache_mem_tracker;
454
    std::shared_ptr<MemTrackerLimiter> _rowsets_no_cache_mem_tracker;
455
    std::shared_ptr<MemTrackerLimiter> _segments_no_cache_mem_tracker;
456
457
    // Tracking memory may be shared between multiple queries.
458
    std::shared_ptr<MemTrackerLimiter> _point_query_executor_mem_tracker;
459
    std::shared_ptr<MemTrackerLimiter> _block_compression_mem_tracker;
460
    std::shared_ptr<MemTrackerLimiter> _query_cache_mem_tracker;
461
462
    // TODO, looking forward to more accurate tracking.
463
    std::shared_ptr<MemTrackerLimiter> _rowid_storage_reader_tracker;
464
    std::shared_ptr<MemTrackerLimiter> _subcolumns_tree_tracker;
465
    std::shared_ptr<MemTrackerLimiter> _s3_file_buffer_tracker;
466
467
    // Tracking memory consumption of parquet meta
468
    std::shared_ptr<MemTrackerLimiter> _parquet_meta_tracker;
469
470
    std::unique_ptr<ThreadPool> _send_batch_thread_pool;
471
    // Threadpool used to prefetch remote file for buffered reader
472
    std::unique_ptr<ThreadPool> _buffered_reader_prefetch_thread_pool;
473
    // Threadpool used to send TableStats to FE
474
    std::unique_ptr<ThreadPool> _send_table_stats_thread_pool;
475
    // Threadpool used to upload local file to s3
476
    std::unique_ptr<ThreadPool> _s3_file_upload_thread_pool;
477
    // Pool used by join node to build hash table
478
    // Pool to use a new thread to release object
479
    std::unique_ptr<ThreadPool> _lazy_release_obj_pool;
480
    std::unique_ptr<ThreadPool> _non_block_close_thread_pool;
481
    std::unique_ptr<ThreadPool> _s3_file_system_thread_pool;
482
    // for java-udf to close
483
    std::unique_ptr<ThreadPool> _udf_close_workers_thread_pool;
484
485
    FragmentMgr* _fragment_mgr = nullptr;
486
    WorkloadGroupMgr* _workload_group_manager = nullptr;
487
488
    ResultCache* _result_cache = nullptr;
489
    ClusterInfo* _cluster_info = nullptr;
490
    LoadPathMgr* _load_path_mgr = nullptr;
491
492
    BfdParser* _bfd_parser = nullptr;
493
    BrokerMgr* _broker_mgr = nullptr;
494
    LoadChannelMgr* _load_channel_mgr = nullptr;
495
    std::unique_ptr<LoadStreamMgr> _load_stream_mgr;
496
    std::unique_ptr<NewLoadStreamMgr> _new_load_stream_mgr;
497
    BrpcClientCache<PBackendService_Stub>* _internal_client_cache = nullptr;
498
    BrpcClientCache<PBackendService_Stub>* _streaming_client_cache = nullptr;
499
    BrpcClientCache<PFunctionService_Stub>* _function_client_cache = nullptr;
500
501
    std::unique_ptr<StreamLoadExecutor> _stream_load_executor;
502
    RoutineLoadTaskExecutor* _routine_load_task_executor = nullptr;
503
    StreamLoadRecorderManager* _stream_load_recorder_manager = nullptr;
504
    SmallFileMgr* _small_file_mgr = nullptr;
505
    HeartbeatFlags* _heartbeat_flags = nullptr;
506
507
    // To save meta info of external file, such as parquet footer.
508
    FileMetaCache* _file_meta_cache = nullptr;
509
    std::unique_ptr<MemTableMemoryLimiter> _memtable_memory_limiter;
510
    std::unique_ptr<LoadStreamMapPool> _load_stream_map_pool;
511
    std::unique_ptr<vectorized::DeltaWriterV2Pool> _delta_writer_v2_pool;
512
    std::unique_ptr<WalManager> _wal_manager;
513
    DNSCache* _dns_cache = nullptr;
514
    std::unique_ptr<WriteCooldownMetaExecutors> _write_cooldown_meta_executors;
515
516
    std::mutex _frontends_lock;
517
    // ip:brpc_port -> frontend_indo
518
    std::map<TNetworkAddress, FrontendInfo> _frontends;
519
    GroupCommitMgr* _group_commit_mgr = nullptr;
520
    CdcClientMgr* _cdc_client_mgr = nullptr;
521
522
    // Maybe we should use unique_ptr, but it need complete type, which means we need
523
    // to include many headers, and for some cpp file that do not need class like TabletSchemaCache,
524
    // these redundancy header could introduce potential bug, at least, more header means slow compile.
525
    // So we choose to use raw pointer, please remember to delete these pointer in deconstructor.
526
    TabletSchemaCache* _tablet_schema_cache = nullptr;
527
    TabletColumnObjectPool* _tablet_column_object_pool = nullptr;
528
    std::unique_ptr<BaseStorageEngine> _storage_engine;
529
    SchemaCache* _schema_cache = nullptr;
530
    StoragePageCache* _storage_page_cache = nullptr;
531
    SegmentLoader* _segment_loader = nullptr;
532
    LookupConnectionCache* _lookup_connection_cache = nullptr;
533
    RowCache* _row_cache = nullptr;
534
    CacheManager* _cache_manager = nullptr;
535
    IdManager* _id_manager = nullptr;
536
    ProcessProfile* _process_profile = nullptr;
537
    HeapProfiler* _heap_profiler = nullptr;
538
    segment_v2::InvertedIndexSearcherCache* _inverted_index_searcher_cache = nullptr;
539
    segment_v2::InvertedIndexQueryCache* _inverted_index_query_cache = nullptr;
540
    segment_v2::EncodingInfoResolver* _encoding_info_resolver = nullptr;
541
    segment_v2::ConditionCache* _condition_cache = nullptr;
542
    QueryCache* _query_cache = nullptr;
543
    std::unique_ptr<io::FDCache> _file_cache_open_fd_cache;
544
    DeleteBitmapAggCache* _delete_bitmap_agg_cache {nullptr};
545
546
    pipeline::RuntimeFilterTimerQueue* _runtime_filter_timer_queue = nullptr;
547
    vectorized::DictionaryFactory* _dict_factory = nullptr;
548
549
    WorkloadSchedPolicyMgr* _workload_sched_mgr = nullptr;
550
    IndexPolicyMgr* _index_policy_mgr = nullptr;
551
552
    RuntimeQueryStatisticsMgr* _runtime_query_statistics_mgr = nullptr;
553
554
    std::unique_ptr<pipeline::PipelineTracerContext> _pipeline_tracer_ctx;
555
    std::unique_ptr<segment_v2::TmpFileDirs> _tmp_file_dirs;
556
    doris::vectorized::SpillStreamManager* _spill_stream_mgr = nullptr;
557
558
    orc::MemoryPool* _orc_memory_pool = nullptr;
559
    arrow::MemoryPool* _arrow_memory_pool = nullptr;
560
561
    kerberos::KerberosTicketMgr* _kerberos_ticket_mgr = nullptr;
562
    io::HdfsMgr* _hdfs_mgr = nullptr;
563
    io::PackedFileManager* _packed_file_manager = nullptr;
564
    S3RateLimiterHolder* _warmup_download_rate_limiter = nullptr;
565
};
566
567
template <>
568
0
inline ClientCache<BackendServiceClient>* ExecEnv::get_client_cache<BackendServiceClient>() {
569
0
    return _backend_client_cache;
570
0
}
571
template <>
572
0
inline ClientCache<FrontendServiceClient>* ExecEnv::get_client_cache<FrontendServiceClient>() {
573
0
    return _frontend_client_cache;
574
0
}
575
template <>
576
inline ClientCache<TPaloBrokerServiceClient>*
577
0
ExecEnv::get_client_cache<TPaloBrokerServiceClient>() {
578
0
    return _broker_client_cache;
579
0
}
580
581
0
inline segment_v2::InvertedIndexQueryCache* GetInvertedIndexQueryCache() {
582
0
    return ExecEnv::GetInstance()->get_inverted_index_query_cache();
583
0
}
584
585
} // namespace doris