Skip to content

Commit f645af1

Browse files
committed
add min max bound test
1 parent 9d0bb2e commit f645af1

1 file changed

Lines changed: 17 additions & 0 deletions

File tree

datafusion/physical-plan/src/filter.rs

Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -347,6 +347,7 @@ impl FilterExec {
347347
)
348348
};
349349

350+
// Estimate (inexact) selectivity of predicate
350351
let num_rows = num_rows.with_estimated_selectivity(selectivity);
351352
let total_byte_size = total_byte_size.with_estimated_selectivity(selectivity);
352353

@@ -2419,6 +2420,22 @@ mod tests {
24192420
)),
24202421
vec![Precision::Exact(1), Precision::Exact(1)],
24212422
),
2423+
(
2424+
"numeric equality with min/max bounds (interval analysis path)",
2425+
vec![Field::new("a", DataType::Int32, false)],
2426+
vec![ColumnStatistics {
2427+
min_value: Precision::Inexact(ScalarValue::Int32(Some(1))),
2428+
max_value: Precision::Inexact(ScalarValue::Int32(Some(100))),
2429+
distinct_count: Precision::Inexact(80),
2430+
..Default::default()
2431+
}],
2432+
Arc::new(BinaryExpr::new(
2433+
Arc::new(Column::new("a", 0)),
2434+
Operator::Eq,
2435+
Arc::new(Literal::new(ScalarValue::Int32(Some(42)))),
2436+
)),
2437+
vec![Precision::Exact(1)],
2438+
),
24222439
(
24232440
"timestamp equality",
24242441
vec![Field::new(

0 commit comments

Comments
 (0)