refactor(flow): expose incremental aggregate plan analysis

Signed-off-by: discord9 <discord9@163.com>
This commit is contained in:
discord9
2026-09-21 19:07:57 +08:00
parent 983738101a
commit e4b72565cd
+4 -1
View File
@@ -48,7 +48,10 @@ pub use batching_mode::task::{
QueryCoverage, TaskArgs,
};
pub use batching_mode::time_window::{TimeWindowExpr, find_time_window_expr};
pub use batching_mode::utils::sql_to_df_plan;
pub use batching_mode::utils::{
IncrementalAggregateAnalysis, IncrementalAggregateMergeColumn, IncrementalAggregateMergeOp,
analyze_incremental_aggregate_plan, sql_to_df_plan,
};
pub(crate) use engine::{CreateFlowArgs, FlowId, TableName};
pub use error::{Error, Result};
pub use server::{FlownodeBuilder, FlownodeInstance, FlownodeServer, FlownodeServiceBuilder};