Skip to content

Commit

Permalink
fix regression comment
Browse files Browse the repository at this point in the history
  • Loading branch information
seawinde committed Nov 13, 2024
1 parent b0cecf4 commit b950f0c
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -804,7 +804,7 @@ private boolean containsNullRejectSlot(Set<Set<Slot>> requireNoNullableViewSlot,
Set<Expression> queryPredicates,
SlotMapping queryToViewMapping,
StructInfo queryStructInfo,
StructInfo viwStructInfo,
StructInfo viewStructInfo,
CascadesContext cascadesContext) {
Set<Expression> queryPulledUpPredicates = queryPredicates.stream()
.flatMap(expr -> ExpressionUtils.extractConjunction(expr).stream())
Expand Down Expand Up @@ -842,7 +842,7 @@ private boolean containsNullRejectSlot(Set<Set<Slot>> requireNoNullableViewSlot,
for (Set<Slot> requireNullableSlots : requireNoNullableViewSlot) {
shuttledRequireNoNullableViewSlot.add(
ExpressionUtils.shuttleExpressionWithLineage(new ArrayList<>(requireNullableSlots),
viwStructInfo.getTopPlan(), new BitSet()).stream().map(Slot.class::cast)
viewStructInfo.getTopPlan(), new BitSet()).stream().map(Slot.class::cast)
.collect(Collectors.toSet()));
}
// query pulledUp predicates should have null reject predicates and contains any require noNullable slot
Expand Down

0 comments on commit b950f0c

Please sign in to comment.