Skip to content

Commit

Permalink
set filter statistics as inexact input if unknown
Browse files Browse the repository at this point in the history
  • Loading branch information
korowa committed Nov 7, 2023
1 parent 436a4fa commit f5ac795
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions datafusion/physical-plan/src/filter.rs
Original file line number Diff line number Diff line change
Expand Up @@ -204,10 +204,11 @@ impl ExecutionPlan for FilterExec {
let predicate = self.predicate();

let schema = self.schema();
let input_stats = self.input.statistics()?;

if !check_support(predicate, &schema) {
return Ok(Statistics::new_unknown(&schema));
return Ok(input_stats.into_inexact());
}
let input_stats = self.input.statistics()?;

let num_rows = input_stats.num_rows;
let total_byte_size = input_stats.total_byte_size;
Expand Down

0 comments on commit f5ac795

Please sign in to comment.