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;