[minor](Nereids): remove useless stream filter() in Translator (#33758)
This commit is contained in:
@ -1383,7 +1383,6 @@ public class PhysicalPlanTranslator extends DefaultPlanVisitor<PlanFragment, Pla
|
||||
|
||||
hashJoin.getOtherJoinConjuncts()
|
||||
.stream()
|
||||
.filter(e -> !(e.equals(BooleanLiteral.TRUE)))
|
||||
.flatMap(e -> e.getInputSlots().stream())
|
||||
.map(SlotReference.class::cast)
|
||||
.forEach(s -> hashOutputSlotReferenceMap.put(s.getExprId(), s));
|
||||
@ -1525,11 +1524,10 @@ public class PhysicalPlanTranslator extends DefaultPlanVisitor<PlanFragment, Pla
|
||||
leftIntermediateSlotDescriptor.forEach(sd -> sd.setIsNullable(true));
|
||||
}
|
||||
|
||||
// Constant expr will cause be crash.
|
||||
// But EliminateJoinCondition and Expression Rewrite already eliminate true literal.
|
||||
List<Expr> otherJoinConjuncts = hashJoin.getOtherJoinConjuncts()
|
||||
.stream()
|
||||
// TODO add constant expr will cause be crash, currently we only handle true literal.
|
||||
// remove it after Nereids could ensure no constant expr in other join condition
|
||||
.filter(e -> !(e.equals(BooleanLiteral.TRUE)))
|
||||
.map(e -> ExpressionTranslator.translate(e, context))
|
||||
.collect(Collectors.toList());
|
||||
|
||||
|
||||
Reference in New Issue
Block a user