mirror/dble
1
0
Fork 0
mirror of https://github.com/actiontech/dble.git synced 2026-01-27 07:50:48 -06:00
Code Issues Packages Projects Releases Wiki Activity

inner 1718 - no need to push down in func (#3211)

Browse Source 
* no need to push down in func

* avoid missing push
This commit is contained in:
Collapsar
2022-04-06 14:55:50 +08:00
committed by GitHub
parent b0fe81f191
commit a39ef77878
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/com/actiontech/dble/plan/optimizer/SelectedProcessor.java
View File

@@ -9,6 +9,7 @@ import com.actiontech.dble.plan.Order;
import com.actiontech.dble.plan.common.item.Item;
import com.actiontech.dble.plan.common.item.ItemField;
import com.actiontech.dble.plan.common.item.function.ItemFunc;
import com.actiontech.dble.plan.common.item.function.operator.cmpfunc.ItemFuncIn;
import com.actiontech.dble.plan.common.item.function.sumfunc.ItemSum;
import com.actiontech.dble.plan.common.item.subquery.ItemSubQuery;
import com.actiontech.dble.plan.node.MergeNode;
@@ -164,7 +165,8 @@ public final class SelectedProcessor {
LinkedHashMap<Item, Item> oldKeyKeyMap = new LinkedHashMap<>();
for (int i = 0; i < selList.size(); i++) {
Item sel = selList.get(i);
if ((child.type() != PlanNode.PlanNodeType.TABLE && sel instanceof ItemFunc) || (child.type() == PlanNode.PlanNodeType.TABLE && sel.isWithSumFunc())) {
if ((child.type() != PlanNode.PlanNodeType.TABLE && sel instanceof ItemFunc) ||
(child.type() == PlanNode.PlanNodeType.TABLE && (sel.isWithSumFunc() || sel instanceof ItemFuncIn))) {
selList.addAll(sel.arguments());
continue;
}