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 group_top_n;
25mod hash_agg;
26mod hop_window;
27mod iceberg_scan;
28mod insert;
29mod join;
30mod limit;
31mod log_row_seq_scan;
32mod max_one_row;
33mod merge_sort;
34mod merge_sort_exchange;
35mod mysql_query;
36mod order_by;
37mod postgres_query;
38mod project;
39mod project_set;
40mod row_seq_scan;
41mod s3_file_scan;
42mod sort_agg;
43mod sort_over_window;
44mod source;
45mod sys_row_seq_scan;
46mod table_function;
47pub mod test_utils;
48mod top_n;
49mod union;
50mod update;
51mod utils;
52mod values;
53
54use azblob_file_scan::AzblobFileScanExecutorBuilder;
55pub use delete::*;
56pub use expand::*;
57pub use filter::*;
58use gcs_file_scan::GcsFileScanExecutorBuilder;
59pub use generic_exchange::*;
60pub use group_top_n::*;
61pub use hash_agg::*;
62pub use hop_window::*;
63pub use iceberg_scan::*;
64pub use insert::*;
65pub use join::*;
66pub use limit::*;
67pub use max_one_row::*;
68pub use merge_sort::*;
69pub use merge_sort_exchange::*;
70pub use mysql_query::*;
71pub use order_by::*;
72pub use postgres_query::*;
73pub use project::*;
74pub use project_set::*;
75pub use row_seq_scan::*;
76use s3_file_scan::FileScanExecutorBuilder;
77pub use sort_agg::*;
78pub use sort_over_window::SortOverWindowExecutor;
79pub use source::*;
80use sys_row_seq_scan::SysRowSeqScanExecutorBuilder;
81pub use table_function::*;
82pub use top_n::TopNExecutor;
83pub use union::*;
84pub use update::*;
85pub use utils::*;
86pub use values::*;
87
88use self::log_row_seq_scan::LogStoreRowSeqScanExecutorBuilder;
89
90register_executor!(RowSeqScan, RowSeqScanExecutorBuilder);
91register_executor!(Insert, InsertExecutor);
92register_executor!(Delete, DeleteExecutor);
93register_executor!(Exchange, GenericExchangeExecutorBuilder);
94register_executor!(Update, UpdateExecutor);
95register_executor!(Filter, FilterExecutor);
96register_executor!(Project, ProjectExecutor);
97register_executor!(SortAgg, SortAggExecutor);
98register_executor!(Sort, SortExecutor);
99register_executor!(TopN, TopNExecutor);
100register_executor!(GroupTopN, GroupTopNExecutorBuilder);
101register_executor!(Limit, LimitExecutor);
102register_executor!(Values, ValuesExecutor);
103register_executor!(NestedLoopJoin, NestedLoopJoinExecutor);
104register_executor!(HashJoin, HashJoinExecutor<()>);
105register_executor!(HashAgg, HashAggExecutorBuilder);
106register_executor!(MergeSortExchange, MergeSortExchangeExecutorBuilder);
107register_executor!(TableFunction, TableFunctionExecutorBuilder);
108register_executor!(HopWindow, HopWindowExecutor);
109register_executor!(SysRowSeqScan, SysRowSeqScanExecutorBuilder);
110register_executor!(Expand, ExpandExecutor);
111register_executor!(LocalLookupJoin, LocalLookupJoinExecutorBuilder);
112register_executor!(DistributedLookupJoin, DistributedLookupJoinExecutorBuilder);
113register_executor!(ProjectSet, ProjectSetExecutor);
114register_executor!(Union, UnionExecutor);
115register_executor!(Source, SourceExecutor);
116register_executor!(SortOverWindow, SortOverWindowExecutor);
117register_executor!(MaxOneRow, MaxOneRowExecutor);
118register_executor!(FileScan, FileScanExecutorBuilder);
119register_executor!(GcsFileScan, GcsFileScanExecutorBuilder);
120register_executor!(AzblobFileScan, AzblobFileScanExecutorBuilder);
121register_executor!(IcebergScan, IcebergScanExecutorBuilder);
122register_executor!(PostgresQuery, PostgresQueryExecutorBuilder);
123register_executor!(MysqlQuery, MySqlQueryExecutorBuilder);
124register_executor!(LogRowSeqScan, LogStoreRowSeqScanExecutorBuilder);
risingwave_batch_executors/executor.rs

risingwave_batch_executors/
executor.rs
