| // Licensed to the Apache Software Foundation (ASF) under one or more | |
| // contributor license agreements. See the NOTICE file distributed with | |
| // this work for additional information regarding copyright ownership. | |
| // The ASF licenses this file to You under the Apache License, Version 2.0 | |
| // (the "License"); you may not use this file except in compliance with | |
| // the License. You may obtain a copy of the License at | |
| // | |
| // http://www.apache.org/licenses/LICENSE-2.0 | |
| // | |
| // Unless required by applicable law or agreed to in writing, software | |
| // distributed under the License is distributed on an "AS IS" BASIS, | |
| // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | |
| // See the License for the specific language governing permissions and | |
| // limitations under the License. | |
| extern crate arrow; | |
| extern crate arrow_schema; | |
| extern crate bytes; | |
| extern crate datafusion; | |
| extern crate datafusion_ext_commons; | |
| extern crate prost; | |
| extern crate prost_reflect; | |
| extern crate rdkafka; | |
| extern crate sonic_rs; | |
| // execution plan implementations | |
| pub mod agg; | |
| pub mod agg_exec; | |
| pub mod broadcast_join_build_hash_map_exec; | |
| pub mod broadcast_join_exec; | |
| pub mod debug_exec; | |
| pub mod empty_partitions_exec; | |
| pub mod expand_exec; | |
| pub mod ffi_reader_exec; | |
| pub mod filter_exec; | |
| pub mod generate_exec; | |
| pub mod ipc_reader_exec; | |
| pub mod ipc_writer_exec; | |
| pub mod joins; | |
| pub mod limit_exec; | |
| pub mod orc_exec; | |
| pub mod orc_sink_exec; | |
| pub mod parquet_exec; | |
| pub mod parquet_sink_exec; | |
| pub mod project_exec; | |
| pub mod rename_columns_exec; | |
| pub mod rss_shuffle_writer_exec; | |
| pub mod shuffle_writer_exec; | |
| pub mod sort_exec; | |
| pub mod sort_merge_join_exec; | |
| pub mod union_exec; | |
| pub mod window_exec; | |
| // helper modules | |
| pub mod common; | |
| pub mod flink; | |
| pub mod generate; | |
| mod scan; | |
| pub mod shuffle; | |
| pub mod window; |