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

[fix](Nereids) expressions is not be extracted when binding function (#15361)

Browse Source
This commit is contained in:
mch_ucchi
2022-12-27 17:12:07 +08:00
committed by GitHub
parent a07ca41f8e
commit 849adca225
1 changed files with 11 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/BindFunction.java
View File

@ -49,10 +49,10 @@ import org.apache.doris.nereids.trees.plans.logical.LogicalSort;
import org.apache.doris.nereids.trees.plans.logical.LogicalTVFRelation;
import com.google.common.collect.ImmutableList;
import com.google.common.collect.ImmutableSet;
import java.util.List;
import java.util.Locale;
import java.util.Set;
import java.util.stream.Collectors;
/**
@ -102,15 +102,15 @@ public class BindFunction implements AnalysisRuleFactory {
RuleType.BINDING_FILTER_FUNCTION.build(
logicalFilter().thenApply(ctx -> {
LogicalFilter<GroupPlan> filter = ctx.root;
List<Expression> conjuncts = bind(filter.getExpressions(), ctx.connectContext.getEnv());
return new LogicalFilter<>(ImmutableSet.copyOf(conjuncts), filter.child());
Set<Expression> conjuncts = bind(filter.getConjuncts(), ctx.connectContext.getEnv());
return new LogicalFilter<>(conjuncts, filter.child());
})
),
RuleType.BINDING_HAVING_FUNCTION.build(
logicalHaving().thenApply(ctx -> {
LogicalHaving<GroupPlan> having = ctx.root;
List<Expression> conjuncts = bind(having.getExpressions(), ctx.connectContext.getEnv());
return new LogicalHaving<>(ImmutableSet.copyOf(conjuncts), having.child());
Set<Expression> conjuncts = bind(having.getConjuncts(), ctx.connectContext.getEnv());
return new LogicalHaving<>(conjuncts, having.child());
})
),
RuleType.BINDING_SORT_FUNCTION.build(
@ -151,6 +151,12 @@ public class BindFunction implements AnalysisRuleFactory {
.collect(Collectors.toList());
}
private <E extends Expression> Set<E> bind(Set<? extends E> exprSet, Env env) {
return exprSet.stream()
.map(expr -> FunctionBinder.INSTANCE.bind(expr, env))
.collect(Collectors.toSet());
}
/**
* function binder
*/