File tree Expand file tree Collapse file tree
datafusion/datasource-parquet/src Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -74,7 +74,6 @@ use arrow::error::{ArrowError, Result as ArrowResult};
7474use arrow:: record_batch:: RecordBatch ;
7575use datafusion_functions:: core:: file_row_index:: FileRowIndexFunc ;
7676use datafusion_functions:: core:: getfield:: GetFieldFunc ;
77- use datafusion_physical_expr_adapter:: expr_references_scalar_udf;
7877use parquet:: arrow:: ProjectionMask ;
7978use parquet:: arrow:: arrow_reader:: { ArrowPredicate , RowFilter } ;
8079use parquet:: file:: metadata:: ParquetMetaData ;
@@ -490,7 +489,9 @@ impl TreeNodeVisitor<'_> for PushdownChecker<'_> {
490489 return Ok ( recursion) ;
491490 }
492491
493- if expr_references_scalar_udf :: < FileRowIndexFunc > ( node) {
492+ if ScalarFunctionExpr :: try_downcast_func :: < FileRowIndexFunc > ( node. as_ref ( ) )
493+ . is_some ( )
494+ {
494495 self . has_unpushable_udfs = true ;
495496 return Ok ( TreeNodeRecursion :: Jump ) ;
496497 }
You can’t perform that action at this time.
0 commit comments