adjust project optimize rule

This commit is contained in:
54liuyao 2024-03-20 11:26:33 +08:00
parent 3cbd30b98d
commit a0346aad2e
1 changed files with 7 additions and 0 deletions

View File

@ -2048,6 +2048,13 @@ static bool eliminateProjOptMayBeOptimized(SLogicNode* pNode) {
TSDB_SUPER_TABLE == ((SScanLogicNode*)nodesListGetNode(pNode->pChildren, 0))->tableType)) { TSDB_SUPER_TABLE == ((SScanLogicNode*)nodesListGetNode(pNode->pChildren, 0))->tableType)) {
return false; return false;
} }
if (QUERY_NODE_LOGIC_PLAN_DYN_QUERY_CTRL == nodeType(nodesListGetNode(pNode->pChildren, 0))) {
SLogicNode* pChild = (SLogicNode*)nodesListGetNode(pNode->pChildren, 0);
if(LIST_LENGTH(pChild->pTargets) != LIST_LENGTH(pNode->pTargets)) {
return false;
}
}
SProjectLogicNode* pProjectNode = (SProjectLogicNode*)pNode; SProjectLogicNode* pProjectNode = (SProjectLogicNode*)pNode;
if (NULL != pProjectNode->node.pLimit || NULL != pProjectNode->node.pSlimit || if (NULL != pProjectNode->node.pLimit || NULL != pProjectNode->node.pSlimit ||