update

luoluoyuyu · luoluoyuyu · commit cfbd0eb4d692 · 2026-04-04T20:50:44.000+08:00
diff --git a/src/coordinator/plan/logical_plan_visitor.rs b/src/coordinator/plan/logical_plan_visitor.rs
@@ -40,9 +40,9 @@ use crate::coordinator::statement::{
 use crate::coordinator::tool::ConnectorOptions;
 use crate::sql::analysis::{StreamSchemaProvider, maybe_add_key_extension_to_sink, rewrite_sinks};
 use crate::sql::common::with_option_keys as opt;
-use crate::sql::extensions::sink::StreamEgressNode;
 use crate::sql::functions::{is_json_union, serialize_outgoing_json};
 use crate::sql::logical_node::logical::{LogicalProgram, ProgramConfig};
+use crate::sql::logical_node::sink::StreamEgressNode;
 use crate::sql::logical_planner::optimizers::{ChainingOptimizer, produce_optimized_plan};
 use crate::sql::logical_planner::planner::PlanToGraphVisitor;
 use crate::sql::rewrite_plan;
diff --git a/src/sql/analysis/aggregate_rewriter.rs b/src/sql/analysis/aggregate_rewriter.rs
@@ -18,8 +18,8 @@ use datafusion::prelude::col;
 use std::sync::Arc;
 
 use crate::sql::analysis::streaming_window_analzer::StreamingWindowAnalzer;
-use crate::sql::extensions::aggregate::StreamWindowAggregateNode;
-use crate::sql::extensions::key_calculation::{KeyExtractionNode, KeyExtractionStrategy};
+use crate::sql::logical_node::aggregate::StreamWindowAggregateNode;
+use crate::sql::logical_node::key_calculation::{KeyExtractionNode, KeyExtractionStrategy};
 use crate::sql::schema::StreamSchemaProvider;
 use crate::sql::types::{
     QualifiedField, TIMESTAMP_FIELD, WindowBehavior, WindowType, build_df_schema_with_metadata,
diff --git a/src/sql/analysis/async_udf_rewriter.rs b/src/sql/analysis/async_udf_rewriter.rs
@@ -11,8 +11,8 @@
 // limitations under the License.
 
 use crate::sql::common::constants::sql_field;
-use crate::sql::extensions::AsyncFunctionExecutionNode;
-use crate::sql::extensions::remote_table::RemoteTableBoundaryNode;
+use crate::sql::logical_node::AsyncFunctionExecutionNode;
+use crate::sql::logical_node::remote_table::RemoteTableBoundaryNode;
 use crate::sql::schema::StreamSchemaProvider;
 use datafusion::common::tree_node::{Transformed, TreeNode, TreeNodeRewriter};
 use datafusion::common::{Column, Result as DFResult, TableReference, plan_err};
diff --git a/src/sql/analysis/join_rewriter.rs b/src/sql/analysis/join_rewriter.rs
@@ -13,8 +13,8 @@
 use crate::sql::analysis::streaming_window_analzer::StreamingWindowAnalzer;
 use crate::sql::common::TIMESTAMP_FIELD;
 use crate::sql::common::constants::mem_exec_join_side;
-use crate::sql::extensions::join::StreamingJoinNode;
-use crate::sql::extensions::key_calculation::KeyExtractionNode;
+use crate::sql::logical_node::join::StreamingJoinNode;
+use crate::sql::logical_node::key_calculation::KeyExtractionNode;
 use crate::sql::schema::StreamSchemaProvider;
 use crate::sql::types::{WindowType, build_df_schema_with_metadata, extract_qualified_fields};
 use datafusion::common::tree_node::{Transformed, TreeNodeRewriter};
diff --git a/src/sql/analysis/mod.rs b/src/sql/analysis/mod.rs
@@ -42,10 +42,10 @@ use datafusion::error::DataFusionError;
 use datafusion::logical_expr::{Extension, LogicalPlan, UserDefinedLogicalNodeCore};
 use tracing::{debug, info, instrument};
 
-use crate::sql::extensions::StreamingOperatorBlueprint;
-use crate::sql::extensions::key_calculation::{KeyExtractionNode, KeyExtractionStrategy};
-use crate::sql::extensions::projection::StreamProjectionNode;
-use crate::sql::extensions::sink::StreamEgressNode;
+use crate::sql::logical_node::StreamingOperatorBlueprint;
+use crate::sql::logical_node::key_calculation::{KeyExtractionNode, KeyExtractionStrategy};
+use crate::sql::logical_node::projection::StreamProjectionNode;
+use crate::sql::logical_node::sink::StreamEgressNode;
 use crate::sql::logical_planner::planner::NamedNode;
 
 fn duration_from_sql_expr(
diff --git a/src/sql/analysis/sink_input_rewriter.rs b/src/sql/analysis/sink_input_rewriter.rs
@@ -10,8 +10,8 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-use crate::sql::extensions::StreamingOperatorBlueprint;
-use crate::sql::extensions::sink::StreamEgressNode;
+use crate::sql::logical_node::StreamingOperatorBlueprint;
+use crate::sql::logical_node::sink::StreamEgressNode;
 use crate::sql::logical_planner::planner::NamedNode;
 use datafusion::common::Result as DFResult;
 use datafusion::common::tree_node::{Transformed, TreeNodeRecursion, TreeNodeRewriter};
diff --git a/src/sql/analysis/source_metadata_visitor.rs b/src/sql/analysis/source_metadata_visitor.rs
@@ -10,8 +10,8 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-use crate::sql::extensions::sink::{STREAM_EGRESS_NODE_NAME, StreamEgressNode};
-use crate::sql::extensions::table_source::{STREAM_INGESTION_NODE_NAME, StreamIngestionNode};
+use crate::sql::logical_node::sink::{STREAM_EGRESS_NODE_NAME, StreamEgressNode};
+use crate::sql::logical_node::table_source::{STREAM_INGESTION_NODE_NAME, StreamIngestionNode};
 use crate::sql::schema::StreamSchemaProvider;
 use datafusion::common::Result as DFResult;
 use datafusion::common::tree_node::{TreeNodeRecursion, TreeNodeVisitor};
diff --git a/src/sql/analysis/source_rewriter.rs b/src/sql/analysis/source_rewriter.rs
@@ -21,10 +21,10 @@ use datafusion::logical_expr::{
 };
 
 use crate::sql::common::UPDATING_META_FIELD;
-use crate::sql::extensions::debezium::UnrollDebeziumPayloadNode;
-use crate::sql::extensions::remote_table::RemoteTableBoundaryNode;
-use crate::sql::extensions::table_source::StreamIngestionNode;
-use crate::sql::extensions::watermark_node::EventTimeWatermarkNode;
+use crate::sql::logical_node::debezium::UnrollDebeziumPayloadNode;
+use crate::sql::logical_node::remote_table::RemoteTableBoundaryNode;
+use crate::sql::logical_node::table_source::StreamIngestionNode;
+use crate::sql::logical_node::watermark_node::EventTimeWatermarkNode;
 use crate::sql::schema::ColumnDescriptor;
 use crate::sql::schema::StreamSchemaProvider;
 use crate::sql::schema::source_table::SourceTable;
diff --git a/src/sql/analysis/stream_rewriter.rs b/src/sql/analysis/stream_rewriter.rs
@@ -19,8 +19,8 @@ use crate::sql::analysis::{
     aggregate_rewriter::AggregateRewriter, join_rewriter::JoinRewriter,
     window_function_rewriter::WindowFunctionRewriter,
 };
-use crate::sql::extensions::StreamingOperatorBlueprint;
-use crate::sql::extensions::remote_table::RemoteTableBoundaryNode;
+use crate::sql::logical_node::StreamingOperatorBlueprint;
+use crate::sql::logical_node::remote_table::RemoteTableBoundaryNode;
 use crate::sql::schema::utils::{add_timestamp_field, has_timestamp_field};
 use crate::sql::types::{QualifiedField, TIMESTAMP_FIELD};
 use datafusion::common::tree_node::{Transformed, TreeNodeRewriter};
diff --git a/src/sql/analysis/streaming_window_analzer.rs b/src/sql/analysis/streaming_window_analzer.rs
@@ -17,8 +17,8 @@ use datafusion::common::tree_node::{TreeNodeRecursion, TreeNodeVisitor};
 use datafusion::common::{Column, DFSchema, DataFusionError, Result};
 use datafusion::logical_expr::{Expr, Extension, LogicalPlan, expr::Alias};
 
-use crate::sql::extensions::aggregate::{STREAM_AGG_EXTENSION_NAME, StreamWindowAggregateNode};
-use crate::sql::extensions::join::STREAM_JOIN_NODE_TYPE;
+use crate::sql::logical_node::aggregate::{STREAM_AGG_EXTENSION_NAME, StreamWindowAggregateNode};
+use crate::sql::logical_node::join::STREAM_JOIN_NODE_TYPE;
 use crate::sql::types::{
     QualifiedField, WindowBehavior, WindowType, extract_qualified_fields, extract_window_type,
 };
diff --git a/src/sql/analysis/window_function_rewriter.rs b/src/sql/analysis/window_function_rewriter.rs
@@ -21,8 +21,8 @@ use std::sync::Arc;
 use tracing::debug;
 
 use crate::sql::analysis::streaming_window_analzer::{StreamingWindowAnalzer, extract_column};
-use crate::sql::extensions::key_calculation::{KeyExtractionNode, KeyExtractionStrategy};
-use crate::sql::extensions::windows_function::StreamingWindowFunctionNode;
+use crate::sql::logical_node::key_calculation::{KeyExtractionNode, KeyExtractionStrategy};
+use crate::sql::logical_node::windows_function::StreamingWindowFunctionNode;
 use crate::sql::types::{WindowType, build_df_schema, extract_qualified_fields};
 
 /// WindowFunctionRewriter transforms standard SQL Window functions into streaming-compatible
diff --git a/src/sql/extensions/mod.rs b/src/sql/extensions/mod.rs
diff --git a/src/sql/logical_node/aggregate.rs b/src/sql/logical_node/aggregate.rs
@@ -33,10 +33,10 @@ use protocol::grpc::api::{
 use crate::multifield_partial_ord;
 use crate::sql::common::constants::{extension_node, proto_operator_name};
 use crate::sql::common::{FsSchema, FsSchemaRef};
-use crate::sql::extensions::{
+use crate::sql::logical_node::logical::{LogicalEdge, LogicalEdgeType, LogicalNode, OperatorName};
+use crate::sql::logical_node::{
     CompiledTopologyNode, StreamingOperatorBlueprint, SystemTimestampInjectorNode,
 };
-use crate::sql::logical_node::logical::{LogicalEdge, LogicalEdgeType, LogicalNode, OperatorName};
 use crate::sql::logical_planner::planner::{NamedNode, Planner, SplitPlanOutput};
 use crate::sql::physical::{StreamingExtensionCodec, window};
 use crate::sql::types::{
diff --git a/src/sql/logical_node/async_udf.rs b/src/sql/logical_node/async_udf.rs
@@ -28,12 +28,12 @@ use crate::multifield_partial_ord;
 use crate::sql::common::constants::extension_node;
 use crate::sql::common::constants::sql_field;
 use crate::sql::common::{FsSchema, FsSchemaRef};
-use crate::sql::extensions::streaming_operator_blueprint::{
-    CompiledTopologyNode, StreamingOperatorBlueprint,
-};
 use crate::sql::logical_node::logical::{
     DylibUdfConfig, LogicalEdge, LogicalEdgeType, LogicalNode, OperatorName,
 };
+use crate::sql::logical_node::streaming_operator_blueprint::{
+    CompiledTopologyNode, StreamingOperatorBlueprint,
+};
 use crate::sql::logical_planner::planner::{NamedNode, Planner};
 use crate::sql::types::{QualifiedField, build_df_schema, extract_qualified_fields};
 
diff --git a/src/sql/logical_node/debezium.rs b/src/sql/logical_node/debezium.rs
diff --git a/src/sql/logical_node/extension_try_from.rs b/src/sql/logical_node/extension_try_from.rs
@@ -15,20 +15,20 @@ use std::sync::Arc;
 use datafusion::common::{DataFusionError, Result};
 use datafusion::logical_expr::UserDefinedLogicalNode;
 
-use crate::sql::extensions::aggregate::StreamWindowAggregateNode;
-use crate::sql::extensions::async_udf::AsyncFunctionExecutionNode;
-use crate::sql::extensions::debezium::{PackDebeziumEnvelopeNode, UnrollDebeziumPayloadNode};
-use crate::sql::extensions::join::StreamingJoinNode;
-use crate::sql::extensions::key_calculation::KeyExtractionNode;
-use crate::sql::extensions::lookup::StreamReferenceJoinNode;
-use crate::sql::extensions::projection::StreamProjectionNode;
-use crate::sql::extensions::remote_table::RemoteTableBoundaryNode;
-use crate::sql::extensions::sink::StreamEgressNode;
-use crate::sql::extensions::streaming_operator_blueprint::StreamingOperatorBlueprint;
-use crate::sql::extensions::table_source::StreamIngestionNode;
-use crate::sql::extensions::updating_aggregate::ContinuousAggregateNode;
-use crate::sql::extensions::watermark_node::EventTimeWatermarkNode;
-use crate::sql::extensions::windows_function::StreamingWindowFunctionNode;
+use crate::sql::logical_node::aggregate::StreamWindowAggregateNode;
+use crate::sql::logical_node::async_udf::AsyncFunctionExecutionNode;
+use crate::sql::logical_node::debezium::{PackDebeziumEnvelopeNode, UnrollDebeziumPayloadNode};
+use crate::sql::logical_node::join::StreamingJoinNode;
+use crate::sql::logical_node::key_calculation::KeyExtractionNode;
+use crate::sql::logical_node::lookup::StreamReferenceJoinNode;
+use crate::sql::logical_node::projection::StreamProjectionNode;
+use crate::sql::logical_node::remote_table::RemoteTableBoundaryNode;
+use crate::sql::logical_node::sink::StreamEgressNode;
+use crate::sql::logical_node::streaming_operator_blueprint::StreamingOperatorBlueprint;
+use crate::sql::logical_node::table_source::StreamIngestionNode;
+use crate::sql::logical_node::updating_aggregate::ContinuousAggregateNode;
+use crate::sql::logical_node::watermark_node::EventTimeWatermarkNode;
+use crate::sql::logical_node::windows_function::StreamingWindowFunctionNode;
 
 fn try_from_t<T: StreamingOperatorBlueprint + 'static>(
     node: &dyn UserDefinedLogicalNode,
diff --git a/src/sql/logical_node/is_retract.rs b/src/sql/logical_node/is_retract.rs
diff --git a/src/sql/logical_node/join.rs b/src/sql/logical_node/join.rs
@@ -24,8 +24,8 @@ use protocol::grpc::api::JoinOperator;
 
 use crate::sql::common::constants::{extension_node, runtime_operator_kind};
 use crate::sql::common::{FsSchema, FsSchemaRef};
-use crate::sql::extensions::{CompiledTopologyNode, StreamingOperatorBlueprint};
 use crate::sql::logical_node::logical::{LogicalEdge, LogicalEdgeType, LogicalNode, OperatorName};
+use crate::sql::logical_node::{CompiledTopologyNode, StreamingOperatorBlueprint};
 use crate::sql::logical_planner::planner::{NamedNode, Planner};
 use crate::sql::physical::StreamingExtensionCodec;
 
diff --git a/src/sql/logical_node/key_calculation.rs b/src/sql/logical_node/key_calculation.rs
@@ -29,8 +29,8 @@ use protocol::grpc::api::{KeyPlanOperator, ProjectionOperator};
 use crate::multifield_partial_ord;
 use crate::sql::common::constants::{extension_node, sql_field};
 use crate::sql::common::{FsSchema, FsSchemaRef};
-use crate::sql::extensions::{CompiledTopologyNode, StreamingOperatorBlueprint};
 use crate::sql::logical_node::logical::{LogicalEdge, LogicalEdgeType, LogicalNode, OperatorName};
+use crate::sql::logical_node::{CompiledTopologyNode, StreamingOperatorBlueprint};
 use crate::sql::logical_planner::planner::{NamedNode, Planner};
 use crate::sql::physical::StreamingExtensionCodec;
 use crate::sql::types::{build_df_schema_with_metadata, extract_qualified_fields};
diff --git a/src/sql/logical_node/lookup.rs b/src/sql/logical_node/lookup.rs
@@ -29,8 +29,8 @@ use protocol::grpc::api::{
 use crate::multifield_partial_ord;
 use crate::sql::common::constants::extension_node;
 use crate::sql::common::{FsSchema, FsSchemaRef};
-use crate::sql::extensions::{CompiledTopologyNode, StreamingOperatorBlueprint};
 use crate::sql::logical_node::logical::{LogicalEdge, LogicalEdgeType, LogicalNode, OperatorName};
+use crate::sql::logical_node::{CompiledTopologyNode, StreamingOperatorBlueprint};
 use crate::sql::logical_planner::planner::{NamedNode, Planner};
 use crate::sql::schema::SourceTable;
 use crate::sql::schema::utils::add_timestamp_field_arrow;
diff --git a/src/sql/logical_node/macros.rs b/src/sql/logical_node/macros.rs
diff --git a/src/sql/logical_node/mod.rs b/src/sql/logical_node/mod.rs
@@ -11,3 +11,32 @@
 // limitations under the License.
 
 pub mod logical;
+
+mod macros;
+
+pub(crate) mod streaming_operator_blueprint;
+pub(crate) use streaming_operator_blueprint::{CompiledTopologyNode, StreamingOperatorBlueprint};
+
+pub(crate) mod aggregate;
+pub(crate) mod debezium;
+pub(crate) mod join;
+pub(crate) mod key_calculation;
+pub(crate) mod lookup;
+pub(crate) mod projection;
+pub(crate) mod remote_table;
+pub(crate) mod sink;
+pub(crate) mod table_source;
+pub(crate) mod updating_aggregate;
+pub(crate) mod watermark_node;
+pub(crate) mod windows_function;
+
+pub(crate) mod timestamp_append;
+pub(crate) use timestamp_append::SystemTimestampInjectorNode;
+
+pub(crate) mod async_udf;
+pub(crate) use async_udf::AsyncFunctionExecutionNode;
+
+pub(crate) mod is_retract;
+pub(crate) use is_retract::IsRetractExtension;
+
+mod extension_try_from;
diff --git a/src/sql/logical_node/projection.rs b/src/sql/logical_node/projection.rs
@@ -24,8 +24,8 @@ use protocol::grpc::api::ProjectionOperator;
 use crate::multifield_partial_ord;
 use crate::sql::common::constants::{extension_node, sql_field};
 use crate::sql::common::{FsSchema, FsSchemaRef};
-use crate::sql::extensions::{CompiledTopologyNode, StreamingOperatorBlueprint};
 use crate::sql::logical_node::logical::{LogicalEdge, LogicalEdgeType, LogicalNode, OperatorName};
+use crate::sql::logical_node::{CompiledTopologyNode, StreamingOperatorBlueprint};
 use crate::sql::logical_planner::planner::{NamedNode, Planner};
 use crate::sql::types::{QualifiedField, build_df_schema};
 
diff --git a/src/sql/logical_node/remote_table.rs b/src/sql/logical_node/remote_table.rs
@@ -24,8 +24,8 @@ use protocol::grpc::api::ValuePlanOperator;
 use crate::multifield_partial_ord;
 use crate::sql::common::constants::extension_node;
 use crate::sql::common::{FsSchema, FsSchemaRef};
-use crate::sql::extensions::{CompiledTopologyNode, StreamingOperatorBlueprint};
 use crate::sql::logical_node::logical::{LogicalEdge, LogicalEdgeType, LogicalNode, OperatorName};
+use crate::sql::logical_node::{CompiledTopologyNode, StreamingOperatorBlueprint};
 use crate::sql::logical_planner::planner::{NamedNode, Planner};
 use crate::sql::physical::StreamingExtensionCodec;
 
diff --git a/src/sql/logical_node/sink.rs b/src/sql/logical_node/sink.rs
@@ -20,8 +20,8 @@ use prost::Message;
 use crate::multifield_partial_ord;
 use crate::sql::common::constants::extension_node;
 use crate::sql::common::{FsSchema, FsSchemaRef, UPDATING_META_FIELD};
-use crate::sql::extensions::{CompiledTopologyNode, StreamingOperatorBlueprint};
 use crate::sql::logical_node::logical::{LogicalEdge, LogicalEdgeType, LogicalNode, OperatorName};
+use crate::sql::logical_node::{CompiledTopologyNode, StreamingOperatorBlueprint};
 use crate::sql::logical_planner::planner::{NamedNode, Planner};
 use crate::sql::schema::Table;
 
diff --git a/src/sql/logical_node/streaming_operator_blueprint.rs b/src/sql/logical_node/streaming_operator_blueprint.rs
diff --git a/src/sql/logical_node/table_source.rs b/src/sql/logical_node/table_source.rs
@@ -20,7 +20,7 @@ use prost::Message;
 use crate::multifield_partial_ord;
 use crate::sql::common::constants::extension_node;
 use crate::sql::common::{FsSchema, FsSchemaRef};
-use crate::sql::extensions::debezium::DebeziumSchemaCodec;
+use crate::sql::logical_node::debezium::DebeziumSchemaCodec;
 use crate::sql::logical_node::logical::{LogicalNode, OperatorName};
 use crate::sql::logical_planner::planner::{NamedNode, Planner};
 use crate::sql::schema::SourceTable;
diff --git a/src/sql/logical_node/timestamp_append.rs b/src/sql/logical_node/timestamp_append.rs
diff --git a/src/sql/logical_node/updating_aggregate.rs b/src/sql/logical_node/updating_aggregate.rs
@@ -27,11 +27,11 @@ use protocol::grpc::api::UpdatingAggregateOperator;
 
 use crate::sql::common::constants::{extension_node, proto_operator_name, updating_state_field};
 use crate::sql::common::{FsSchema, FsSchemaRef};
-use crate::sql::extensions::{
-    CompiledTopologyNode, IsRetractExtension, StreamingOperatorBlueprint,
-};
 use crate::sql::functions::multi_hash;
 use crate::sql::logical_node::logical::{LogicalEdge, LogicalEdgeType, LogicalNode, OperatorName};
+use crate::sql::logical_node::{
+    CompiledTopologyNode, IsRetractExtension, StreamingOperatorBlueprint,
+};
 use crate::sql::logical_planner::planner::{NamedNode, Planner};
 use crate::sql::physical::StreamingExtensionCodec;
 
diff --git a/src/sql/logical_node/watermark_node.rs b/src/sql/logical_node/watermark_node.rs
@@ -24,8 +24,8 @@ use protocol::grpc::api::ExpressionWatermarkConfig;
 use crate::multifield_partial_ord;
 use crate::sql::common::constants::{extension_node, runtime_operator_kind};
 use crate::sql::common::{FsSchema, FsSchemaRef};
-use crate::sql::extensions::{CompiledTopologyNode, StreamingOperatorBlueprint};
 use crate::sql::logical_node::logical::{LogicalEdge, LogicalEdgeType, LogicalNode, OperatorName};
+use crate::sql::logical_node::{CompiledTopologyNode, StreamingOperatorBlueprint};
 use crate::sql::logical_planner::planner::{NamedNode, Planner};
 use crate::sql::schema::utils::add_timestamp_field;
 use crate::sql::types::TIMESTAMP_FIELD;
diff --git a/src/sql/logical_node/windows_function.rs b/src/sql/logical_node/windows_function.rs
diff --git a/src/sql/logical_planner/streaming_planner.rs b/src/sql/logical_planner/streaming_planner.rs
@@ -43,12 +43,12 @@ use datafusion_proto::physical_plan::DefaultPhysicalExtensionCodec;
 use datafusion_proto::physical_plan::to_proto::serialize_physical_expr;
 
 use crate::sql::common::{FsSchema, FsSchemaRef};
-use crate::sql::extensions::debezium::{
+use crate::sql::logical_node::debezium::{
     PACK_NODE_NAME, UNROLL_NODE_NAME, UnrollDebeziumPayloadNode,
 };
-use crate::sql::extensions::key_calculation::KeyExtractionNode;
-use crate::sql::extensions::{CompiledTopologyNode, StreamingOperatorBlueprint};
+use crate::sql::logical_node::key_calculation::KeyExtractionNode;
 use crate::sql::logical_node::logical::{LogicalEdge, LogicalGraph, LogicalNode};
+use crate::sql::logical_node::{CompiledTopologyNode, StreamingOperatorBlueprint};
 use crate::sql::physical::{
     CdcDebeziumPackExec, CdcDebeziumUnrollExec, FsMemExec, StreamingDecodingContext,
     StreamingExtensionCodec,
diff --git a/src/sql/mod.rs b/src/sql/mod.rs
@@ -14,7 +14,6 @@ pub mod api;
 pub mod common;
 
 pub mod analysis;
-pub(crate) mod extensions;
 pub mod functions;
 pub mod logical_node;
 pub mod logical_planner;
diff --git a/src/sql/schema/table.rs b/src/sql/schema/table.rs
@@ -12,7 +12,7 @@
 
 use super::source_table::SourceTable;
 use crate::sql::analysis::rewrite_plan;
-use crate::sql::extensions::remote_table::RemoteTableBoundaryNode;
+use crate::sql::logical_node::remote_table::RemoteTableBoundaryNode;
 use crate::sql::logical_planner::optimizers::produce_optimized_plan;
 use crate::sql::schema::StreamSchemaProvider;
 use crate::sql::types::{ProcessingMode, QualifiedField};
