feat(query): refactor vacuum temp files (#17089)

* update * update * update * update * update * update * update * fix * fix * update * update * Update push_down_filter_join_left_outer.test * update tests * update tests * update tests * update reset
databendlabs · Dec 23, 2024 · 0e12f28 · 0e12f28
1 parent 793e2ae
commit 0e12f28
Show file tree

Hide file tree

Showing 42 changed files with 684 additions and 524 deletions.
diff --git a/src/query/ee/src/storages/fuse/operations/handler.rs b/src/query/ee/src/storages/fuse/operations/handler.rs
@@ -13,7 +13,6 @@
 // limitations under the License.
 
 use std::sync::Arc;
-use std::time::Duration;
 
 use chrono::DateTime;
 use chrono::Utc;
@@ -24,6 +23,7 @@ use databend_common_catalog::table_context::TableContext;
 use databend_common_exception::Result;
 use databend_common_storages_fuse::FuseTable;
 use databend_enterprise_vacuum_handler::vacuum_handler::VacuumDropTablesResult;
+use databend_enterprise_vacuum_handler::vacuum_handler::VacuumTempOptions;
 use databend_enterprise_vacuum_handler::VacuumHandler;
 use databend_enterprise_vacuum_handler::VacuumHandlerWrapper;
 
@@ -57,10 +57,10 @@ impl VacuumHandler for RealVacuumHandler {
         &self,
         abort_checker: AbortChecker,
         temporary_dir: String,
-        retain: Option<Duration>,
+        options: &VacuumTempOptions,
         vacuum_limit: usize,
     ) -> Result<usize> {
-        do_vacuum_temporary_files(abort_checker, temporary_dir, retain, vacuum_limit).await
+        do_vacuum_temporary_files(abort_checker, temporary_dir, options, vacuum_limit).await
     }
 }