From 40cf63d3c407cf4daae9c6ac0599594484d09972 Mon Sep 17 00:00:00 2001 From: Ruihang Xia Date: Mon, 3 Mar 2025 19:54:07 -0800 Subject: [PATCH] refactor: rename table function to admin function (#5636) * refactor: rename table function to admin function Signed-off-by: Ruihang Xia * format Signed-off-by: Ruihang Xia --------- Signed-off-by: Ruihang Xia --- src/common/function/src/{table.rs => admin.rs} | 4 ++-- .../function/src/{table => admin}/flush_compact_region.rs | 0 .../function/src/{table => admin}/flush_compact_table.rs | 0 src/common/function/src/{table => admin}/migrate_region.rs | 0 src/common/function/src/function_registry.rs | 4 ++-- src/common/function/src/lib.rs | 2 +- 6 files changed, 5 insertions(+), 5 deletions(-) rename src/common/function/src/{table.rs => admin.rs} (96%) rename src/common/function/src/{table => admin}/flush_compact_region.rs (100%) rename src/common/function/src/{table => admin}/flush_compact_table.rs (100%) rename src/common/function/src/{table => admin}/migrate_region.rs (100%) diff --git a/src/common/function/src/table.rs b/src/common/function/src/admin.rs similarity index 96% rename from src/common/function/src/table.rs rename to src/common/function/src/admin.rs index 91ee6dd178..b2f916d876 100644 --- a/src/common/function/src/table.rs +++ b/src/common/function/src/admin.rs @@ -26,9 +26,9 @@ use crate::flush_flow::FlushFlowFunction; use crate::function_registry::FunctionRegistry; /// Table functions -pub(crate) struct TableFunction; +pub(crate) struct AdminFunction; -impl TableFunction { +impl AdminFunction { /// Register all table functions to [`FunctionRegistry`]. pub fn register(registry: &FunctionRegistry) { registry.register_async(Arc::new(MigrateRegionFunction)); diff --git a/src/common/function/src/table/flush_compact_region.rs b/src/common/function/src/admin/flush_compact_region.rs similarity index 100% rename from src/common/function/src/table/flush_compact_region.rs rename to src/common/function/src/admin/flush_compact_region.rs diff --git a/src/common/function/src/table/flush_compact_table.rs b/src/common/function/src/admin/flush_compact_table.rs similarity index 100% rename from src/common/function/src/table/flush_compact_table.rs rename to src/common/function/src/admin/flush_compact_table.rs diff --git a/src/common/function/src/table/migrate_region.rs b/src/common/function/src/admin/migrate_region.rs similarity index 100% rename from src/common/function/src/table/migrate_region.rs rename to src/common/function/src/admin/migrate_region.rs diff --git a/src/common/function/src/function_registry.rs b/src/common/function/src/function_registry.rs index 1761f6ef50..f786623ac0 100644 --- a/src/common/function/src/function_registry.rs +++ b/src/common/function/src/function_registry.rs @@ -18,6 +18,7 @@ use std::sync::{Arc, RwLock}; use once_cell::sync::Lazy; +use crate::admin::AdminFunction; use crate::function::{AsyncFunctionRef, FunctionRef}; use crate::scalars::aggregate::{AggregateFunctionMetaRef, AggregateFunctions}; use crate::scalars::date::DateFunction; @@ -30,7 +31,6 @@ use crate::scalars::timestamp::TimestampFunction; use crate::scalars::uddsketch_calc::UddSketchCalcFunction; use crate::scalars::vector::VectorFunction; use crate::system::SystemFunction; -use crate::table::TableFunction; #[derive(Default)] pub struct FunctionRegistry { @@ -118,7 +118,7 @@ pub static FUNCTION_REGISTRY: Lazy> = Lazy::new(|| { // System and administration functions SystemFunction::register(&function_registry); - TableFunction::register(&function_registry); + AdminFunction::register(&function_registry); // Json related functions JsonFunction::register(&function_registry); diff --git a/src/common/function/src/lib.rs b/src/common/function/src/lib.rs index a553e8924b..ea5e20ee3c 100644 --- a/src/common/function/src/lib.rs +++ b/src/common/function/src/lib.rs @@ -15,11 +15,11 @@ #![feature(let_chains)] #![feature(try_blocks)] +mod admin; mod flush_flow; mod macros; pub mod scalars; mod system; -mod table; pub mod aggr; pub mod function;