Skip to content

Commit 891d415

Browse files
committed
Stop copying LogicalPlan and Exprs in PushDownFilter
1 parent 53de994 commit 891d415

File tree

2 files changed

+343
-290
lines changed

2 files changed

+343
-290
lines changed

datafusion/expr/src/logical_plan/plan.rs

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2368,6 +2368,16 @@ pub enum Distinct {
23682368
On(DistinctOn),
23692369
}
23702370

2371+
impl Distinct {
2372+
/// return a reference to the nodes input
2373+
pub fn input(&self) -> &Arc<LogicalPlan> {
2374+
match self {
2375+
Distinct::All(input) => input,
2376+
Distinct::On(DistinctOn { input, .. }) => input,
2377+
}
2378+
}
2379+
}
2380+
23712381
/// Removes duplicate rows from the input
23722382
#[derive(Clone, PartialEq, Eq, Hash)]
23732383
pub struct DistinctOn {

0 commit comments

Comments
 (0)