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

[exec](runtimefilter) support null aware in runtime filter (#32152)

Browse Source 
null aware in runtime filter
This commit is contained in:
HappenLee
2024-03-14 17:59:15 +08:00
committed by yiguolei
parent aca7328109
commit c8f3643890
10 changed files with 81 additions and 41 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/AbstractPhysicalPlan.java
View File

@ -135,10 +135,8 @@ public abstract class AbstractPhysicalPlan extends AbstractPlan implements Physi
} else {
// null safe equal runtime filter only support bloom filter
EqualPredicate eq = (EqualPredicate) builderNode.getHashJoinConjuncts().get(exprOrder);
if (eq instanceof NullSafeEqual && type == TRuntimeFilterType.IN_OR_BLOOM) {
type = TRuntimeFilterType.BLOOM;
}
if (eq instanceof NullSafeEqual && type != TRuntimeFilterType.BLOOM) {
if (eq instanceof NullSafeEqual && type == TRuntimeFilterType.MIN_MAX
|| type == TRuntimeFilterType.BITMAP) {
return false;
}
filter = new RuntimeFilter(generator.getNextId(),