Skip to content

Commit a893cff

Browse files
committed
Added support for Views.
1 parent 331c09d commit a893cff

2 files changed

Lines changed: 3 additions & 0 deletions

File tree

crates/execution/src/pipelined.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -186,6 +186,7 @@ impl ViewProject {
186186
let mut n = 0;
187187
let mut bytes_scanned = 0;
188188
self.inner.execute(tx, metrics, &mut |row| match row {
189+
Row::Null => Ok(()),
189190
Row::Ptr(ptr) => {
190191
n += 1;
191192
let col_list = ColList::from_iter(self.num_private_cols..self.num_cols);

crates/physical-plan/src/plan.rs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -586,6 +586,7 @@ impl PhysicalPlan {
586586
lhs_field,
587587
rhs_field,
588588
unique,
589+
outer,
589590
},
590591
semi,
591592
) => Self::HashJoin(
@@ -595,6 +596,7 @@ impl PhysicalPlan {
595596
lhs_field,
596597
rhs_field,
597598
unique,
599+
outer,
598600
},
599601
semi,
600602
),

0 commit comments

Comments
 (0)