From ea7c17089f2ded9ec0db215b42856a700645c287 Mon Sep 17 00:00:00 2001 From: zyy17 Date: Mon, 24 Jun 2024 16:25:52 +0800 Subject: [PATCH] refactor: add `region_dir` in CompactionRegion (#4187) --- src/mito2/src/compaction.rs | 1 + src/mito2/src/compaction/compactor.rs | 12 +++++++----- 2 files changed, 8 insertions(+), 5 deletions(-) diff --git a/src/mito2/src/compaction.rs b/src/mito2/src/compaction.rs index 2eb0cf3d85..5236c5d28d 100644 --- a/src/mito2/src/compaction.rs +++ b/src/mito2/src/compaction.rs @@ -276,6 +276,7 @@ impl CompactionScheduler { let compaction_region = CompactionRegion { region_id, + region_dir: access_layer.region_dir().to_string(), current_version: current_version.clone(), region_options: current_version.options.clone(), engine_config: engine_config.clone(), diff --git a/src/mito2/src/compaction/compactor.rs b/src/mito2/src/compaction/compactor.rs index c7e4f67c29..50cf0d09e6 100644 --- a/src/mito2/src/compaction/compactor.rs +++ b/src/mito2/src/compaction/compactor.rs @@ -54,6 +54,7 @@ use crate::sst::parquet::WriteOptions; pub struct CompactionRegion { pub region_id: RegionId, pub region_options: RegionOptions, + pub region_dir: String, pub(crate) engine_config: Arc, pub(crate) region_metadata: RegionMetadataRef, @@ -163,14 +164,15 @@ pub async fn open_compaction_region( }; Ok(CompactionRegion { - region_options: region_options.clone(), - manifest_ctx, - access_layer, - current_version, region_id: req.region_id, - cache_manager: Arc::new(CacheManager::default()), + region_options: region_options.clone(), + region_dir: req.region_dir.clone(), engine_config: Arc::new(mito_config.clone()), region_metadata: region_metadata.clone(), + cache_manager: Arc::new(CacheManager::default()), + access_layer, + manifest_ctx, + current_version, }) }