database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](Nereids) variant push down not work on slot without table (#33356)

Browse Source
This commit is contained in:
morrySnow
2024-04-08 16:04:04 +08:00
committed by yiguolei
parent 53505e903b
commit ecbd92204d
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/PushDownToProjectionFunction.java
View File

@ -60,6 +60,10 @@ public abstract class PushDownToProjectionFunction extends ScalarFunction {
* Otherwise, a new SlotReference is created and added to the context.
*/
public static Expression rewriteToSlot(PushDownToProjectionFunction pushedFunction, SlotReference topColumnSlot) {
// push down could not work well with variant that not belong to table, so skip it.
if (!topColumnSlot.getColumn().isPresent() || !topColumnSlot.getTable().isPresent()) {
return pushedFunction;
}
// rewrite to slotRef
StatementContext ctx = ConnectContext.get().getStatementContext();
List<String> fullPaths = pushedFunction.collectToList(node -> node instanceof VarcharLiteral).stream()
@ -73,8 +77,8 @@ public abstract class PushDownToProjectionFunction extends ScalarFunction {
boolean nullable = true; // always nullable at present
SlotReference slotRef = new SlotReference(StatementScopeIdGenerator.newExprId(),
topColumnSlot.getName(), topColumnSlot.getDataType(),
nullable, topColumnSlot.getQualifier(), topColumnSlot.getTable().orElse(null),
topColumnSlot.getColumn().orElse(null), Optional.of(topColumnSlot.getInternalName()),
nullable, topColumnSlot.getQualifier(), topColumnSlot.getTable().get(),
topColumnSlot.getColumn().get(), Optional.of(topColumnSlot.getInternalName()),
fullPaths);
ctx.addPathSlotRef(topColumnSlot, fullPaths, slotRef, pushedFunction);
ctx.addSlotToRelation(slotRef, ctx.getRelationBySlot(topColumnSlot));