Skip to content

Commit 7f63d43

Browse files
committed
Implement cardinality_effect for UnionExec
1 parent 85d8c39 commit 7f63d43

1 file changed

Lines changed: 6 additions & 2 deletions

File tree

datafusion/physical-plan/src/union.rs

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -33,8 +33,8 @@ use super::{
3333
metrics::{ExecutionPlanMetricsSet, MetricsSet},
3434
};
3535
use crate::execution_plan::{
36-
InvariantLevel, boundedness_from_children, check_default_invariants,
37-
emission_type_from_children,
36+
CardinalityEffect, InvariantLevel, boundedness_from_children,
37+
check_default_invariants, emission_type_from_children,
3838
};
3939
use crate::filter::FilterExec;
4040
use crate::filter_pushdown::{
@@ -343,6 +343,10 @@ impl ExecutionPlan for UnionExec {
343343
}
344344
}
345345

346+
fn cardinality_effect(&self) -> CardinalityEffect {
347+
CardinalityEffect::GreaterEqual
348+
}
349+
346350
fn supports_limit_pushdown(&self) -> bool {
347351
true
348352
}

0 commit comments

Comments
 (0)