risingwave_batch_executors/
executor.rs

1// Copyright 2025 RisingWave Labs
2//
3// Licensed under the Apache License, Version 2.0 (the "License");
4// you may not use this file except in compliance with the License.
5// You may obtain a copy of the License at
6//
7//     http://www.apache.org/licenses/LICENSE-2.0
8//
9// Unless required by applicable law or agreed to in writing, software
10// distributed under the License is distributed on an "AS IS" BASIS,
11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12// See the License for the specific language governing permissions and
13// limitations under the License.
14
15pub use risingwave_batch::executor::*;
16
17pub mod aggregation;
18mod azblob_file_scan;
19mod delete;
20mod expand;
21mod filter;
22mod gcs_file_scan;
23mod generic_exchange;
24mod get_channel_delta_stats;
25mod group_top_n;
26mod hash_agg;
27mod hop_window;
28mod iceberg_scan;
29mod insert;
30mod join;
31mod limit;
32mod log_row_seq_scan;
33mod max_one_row;
34mod merge_sort;
35mod merge_sort_exchange;
36mod mysql_query;
37mod order_by;
38mod postgres_query;
39mod project;
40mod project_set;
41mod row_seq_scan;
42mod s3_file_scan;
43mod sort_agg;
44mod sort_over_window;
45mod source;
46mod sys_row_seq_scan;
47mod table_function;
48pub mod test_utils;
49mod top_n;
50mod union;
51mod update;
52mod utils;
53mod values;
54mod vector_index_nearest;
55
56use azblob_file_scan::AzblobFileScanExecutorBuilder;
57pub use delete::*;
58pub use expand::*;
59pub use filter::*;
60use gcs_file_scan::GcsFileScanExecutorBuilder;
61pub use generic_exchange::*;
62use get_channel_delta_stats::GetChannelDeltaStatsExecutor;
63pub use group_top_n::*;
64pub use hash_agg::*;
65pub use hop_window::*;
66pub use iceberg_scan::*;
67pub use insert::*;
68pub use join::*;
69pub use limit::*;
70use log_row_seq_scan::LogStoreRowSeqScanExecutorBuilder;
71pub use max_one_row::*;
72pub use merge_sort::*;
73pub use merge_sort_exchange::*;
74pub use mysql_query::*;
75pub use order_by::*;
76pub use postgres_query::*;
77pub use project::*;
78pub use project_set::*;
79pub use row_seq_scan::*;
80use s3_file_scan::FileScanExecutorBuilder;
81pub use sort_agg::*;
82pub use sort_over_window::SortOverWindowExecutor;
83pub use source::*;
84use sys_row_seq_scan::SysRowSeqScanExecutorBuilder;
85pub use table_function::*;
86pub use top_n::TopNExecutor;
87pub use union::*;
88pub use update::*;
89pub use utils::*;
90pub use values::*;
91use vector_index_nearest::VectorIndexNearestExecutorBuilder;
92
93register_executor!(RowSeqScan, RowSeqScanExecutorBuilder);
94register_executor!(Insert, InsertExecutor);
95register_executor!(Delete, DeleteExecutor);
96register_executor!(Exchange, GenericExchangeExecutorBuilder);
97register_executor!(Update, UpdateExecutor);
98register_executor!(Filter, FilterExecutor);
99register_executor!(Project, ProjectExecutor);
100register_executor!(SortAgg, SortAggExecutor);
101register_executor!(Sort, SortExecutor);
102register_executor!(TopN, TopNExecutor);
103register_executor!(GroupTopN, GroupTopNExecutorBuilder);
104register_executor!(Limit, LimitExecutor);
105register_executor!(Values, ValuesExecutor);
106register_executor!(NestedLoopJoin, NestedLoopJoinExecutor);
107register_executor!(HashJoin, HashJoinExecutor<()>);
108register_executor!(HashAgg, HashAggExecutorBuilder);
109register_executor!(MergeSortExchange, MergeSortExchangeExecutorBuilder);
110register_executor!(TableFunction, TableFunctionExecutorBuilder);
111register_executor!(HopWindow, HopWindowExecutor);
112register_executor!(SysRowSeqScan, SysRowSeqScanExecutorBuilder);
113register_executor!(Expand, ExpandExecutor);
114register_executor!(LocalLookupJoin, LocalLookupJoinExecutorBuilder);
115register_executor!(DistributedLookupJoin, DistributedLookupJoinExecutorBuilder);
116register_executor!(ProjectSet, ProjectSetExecutor);
117register_executor!(Union, UnionExecutor);
118register_executor!(Source, SourceExecutor);
119register_executor!(SortOverWindow, SortOverWindowExecutor);
120register_executor!(MaxOneRow, MaxOneRowExecutor);
121register_executor!(FileScan, FileScanExecutorBuilder);
122register_executor!(GcsFileScan, GcsFileScanExecutorBuilder);
123register_executor!(AzblobFileScan, AzblobFileScanExecutorBuilder);
124register_executor!(IcebergScan, IcebergScanExecutorBuilder);
125register_executor!(PostgresQuery, PostgresQueryExecutorBuilder);
126register_executor!(MysqlQuery, MySqlQueryExecutorBuilder);
127register_executor!(LogRowSeqScan, LogStoreRowSeqScanExecutorBuilder);
128register_executor!(GetChannelDeltaStats, GetChannelDeltaStatsExecutor);
129register_executor!(VectorIndexNearest, VectorIndexNearestExecutorBuilder);
risingwave_batch_executors/executor.rs

risingwave_batch_executors/
executor.rs
