risingwave_batch_executors/
executor.rs

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

risingwave_batch_executors/
executor.rs
