File tree Expand file tree Collapse file tree
datafusion/physical-plan/src Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -341,7 +341,10 @@ impl FilterExec {
341341 schema,
342342 & input_stats. column_statistics ,
343343 analysis_ctx. boundaries ,
344- num_rows. get_value ( ) . copied ( ) ,
344+ match & num_rows {
345+ Precision :: Absent => None ,
346+ p => Some ( * p) ,
347+ } ,
345348 ) ;
346349 Ok ( Statistics {
347350 num_rows,
@@ -782,7 +785,7 @@ fn collect_new_statistics(
782785 schema : & SchemaRef ,
783786 input_column_stats : & [ ColumnStatistics ] ,
784787 analysis_boundaries : Vec < ExprBoundaries > ,
785- filtered_num_rows : Option < usize > ,
788+ filtered_num_rows : Option < Precision < usize > > ,
786789) -> Vec < ColumnStatistics > {
787790 analysis_boundaries
788791 . into_iter ( )
@@ -824,9 +827,7 @@ fn collect_new_statistics(
824827 Precision :: Exact ( 1 )
825828 } else {
826829 match filtered_num_rows {
827- Some ( rows) => {
828- distinct_count. to_inexact ( ) . min ( & Precision :: Inexact ( rows) )
829- }
830+ Some ( rows) => distinct_count. to_inexact ( ) . min ( & rows) ,
830831 None => distinct_count. to_inexact ( ) ,
831832 }
832833 } ;
You can’t perform that action at this time.
0 commit comments