Skip to content

Commit e4e66b1

Browse files
authored
chore: [comet-parquet-exec] Fix filter import (#1297)
* Use CometFilterExec not DataFusion FilterExec * fix test
1 parent 32b9338 commit e4e66b1

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

native/core/src/execution/planner.rs

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@
1818
//! Converts Spark physical plan to DataFusion physical plan
1919
2020
use super::expressions::EvalMode;
21-
use crate::execution::operators::CopyMode;
21+
use crate::execution::operators::{CopyMode, FilterExec};
2222
use crate::{
2323
errors::ExpressionError,
2424
execution::{
@@ -37,7 +37,6 @@ use datafusion::functions_aggregate::bit_and_or_xor::{bit_and_udaf, bit_or_udaf,
3737
use datafusion::functions_aggregate::min_max::max_udaf;
3838
use datafusion::functions_aggregate::min_max::min_udaf;
3939
use datafusion::functions_aggregate::sum::sum_udaf;
40-
use datafusion::physical_plan::filter::FilterExec;
4140
use datafusion::physical_plan::windows::BoundedWindowAggExec;
4241
use datafusion::physical_plan::InputOrderMode;
4342
use datafusion::{
@@ -2767,7 +2766,7 @@ mod tests {
27672766

27682767
let (mut _scans, filter_exec) = planner.create_plan(&op, &mut vec![], 1).unwrap();
27692768

2770-
assert_eq!("FilterExec", filter_exec.native_plan.name());
2769+
assert_eq!("CometFilterExec", filter_exec.native_plan.name());
27712770
assert_eq!(1, filter_exec.children.len());
27722771
assert_eq!(0, filter_exec.additional_native_plans.len());
27732772
}

0 commit comments

Comments
 (0)