xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

calcNeedCountEmpty

This commit is contained in:
Bob Liu 2023-12-24 01:19:16 +08:00
parent 6e4703e5b4
commit c9b69316c1
5 changed files with 23 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
include/libs/nodes/plannodes.h
View File

@ -147,6 +147,7 @@ typedef struct SAggLogicNode {
bool isGroupTb;
bool isPartTb; // true if partition keys has tbname
bool hasGroup;
bool isCountByTag; // true if hasCountFunc & part by tag/tbname
} SAggLogicNode;
typedef struct SProjectLogicNode {

1
source/libs/nodes/src/nodesCloneFuncs.c
View File

@ -453,6 +453,7 @@ static int32_t logicAggCopy(const SAggLogicNode* pSrc, SAggLogicNode* pDst) {
COPY_SCALAR_FIELD(isGroupTb);
COPY_SCALAR_FIELD(isPartTb);
COPY_SCALAR_FIELD(hasGroup);
COPY_SCALAR_FIELD(isCountByTag);
return TSDB_CODE_SUCCESS;
}

9
source/libs/planner/src/planLogicCreater.c
View File

@ -748,6 +748,15 @@ static int32_t createAggLogicNode(SLogicPlanContext* pCxt, SSelectStmt* pSelect,
pAgg->isGroupTb = pAgg->pGroupKeys ? keysHasTbname(pAgg->pGroupKeys) : 0;
pAgg->isPartTb = pSelect->pPartitionByList ? keysHasTbname(pSelect->pPartitionByList) : 0;
pAgg->hasGroup = pAgg->pGroupKeys || pSelect->pPartitionByList;
bool isCountByTag = false;
if (pSelect->hasCountFunc) {
if (pSelect->pGroupByList) {
isCountByTag = !keysHasCol(pSelect->pGroupByList);
} else if (pSelect->pPartitionByList) {
isCountByTag = !keysHasCol(pSelect->pPartitionByList);
}
}
pAgg->isCountByTag = isCountByTag;
if (TSDB_CODE_SUCCESS == code) {
*pLogicNode = (SLogicNode*)pAgg;

1
source/libs/planner/src/planOptimizer.c
View File

@ -2783,6 +2783,7 @@ static int32_t splitCacheLastFuncOptCreateAggLogicNode(SAggLogicNode** pNewAgg,
pNew->isGroupTb = pAgg->isGroupTb;
pNew->isPartTb = pAgg->isPartTb;
pNew->hasGroup = pAgg->hasGroup;
pNew->isCountByTag = pAgg->isCountByTag;
pNew->node.pChildren = nodesCloneList(pAgg->node.pChildren);
int32_t code = 0;

22
source/libs/planner/src/planPhysiCreater.c
View File

@ -37,6 +37,7 @@ typedef struct SPhysiPlanContext {
SArray* pLocationHelper;
bool hasScan;
bool hasSysScan;
SLogicNode* pNode; // tmp record LogicSubplan->pNode
} SPhysiPlanContext;
static int32_t getSlotKey(SNode* pNode, const char* pStmtName, char* pKey, int32_t keyBufSize) {
@ -592,17 +593,13 @@ static bool calcNeedCountEmpty(SPhysiPlanContext* pCxt, SScanLogicNode* pScanLog
if (pScanLogicNode->interval > 0) {
return false;
}
// limit: root node is select
SNode* pRoot = pCxt->pPlanCxt->pAstRoot;
if (QUERY_NODE_SELECT_STMT == nodeType(pRoot)) {
SSelectStmt* pSelect = (SSelectStmt*)pRoot;
// select & count
if (pSelect->hasCountFunc) {
// key only accept tag/tbname
if (NULL != pSelect->pGroupByList) {
return !keysHasCol(pSelect->pGroupByList);
} else if (NULL != pSelect->pPartitionByList) {
return !keysHasCol(pSelect->pPartitionByList);
}
if (QUERY_NODE_SELECT_STMT == nodeType(pRoot)
&& pCxt->pNode && QUERY_NODE_LOGIC_PLAN_AGG == nodeType(pCxt->pNode)) {
SAggLogicNode* pNode = (SAggLogicNode*)pCxt->pNode;
if (pNode->isCountByTag) {
return true;
}
}
return false;
@ -2302,7 +2299,9 @@ static int32_t createPhysiSubplan(SPhysiPlanContext* pCxt, SLogicSubplan* pLogic
} else {
pSubplan->msgType = TDMT_SCH_MERGE_QUERY;
}
pCxt->pNode = pLogicSubplan->pNode;
code = createPhysiNode(pCxt, pLogicSubplan->pNode, pSubplan, &pSubplan->pNode);
pCxt->pNode = NULL;
if (TSDB_CODE_SUCCESS == code && !pCxt->pPlanCxt->streamQuery && !pCxt->pPlanCxt->topicQuery) {
code = createDataDispatcher(pCxt, pSubplan->pNode, &pSubplan->pDataSink);
}
@ -2454,7 +2453,8 @@ int32_t createPhysiPlan(SPlanContext* pCxt, SQueryLogicPlan* pLogicPlan, SQueryP
.nextDataBlockId = 0,
.pLocationHelper = taosArrayInit(32, POINTER_BYTES),
.hasScan = false,
.hasSysScan = false};
.hasSysScan = false,
.pNode = NULL};
if (NULL == cxt.pLocationHelper) {
return TSDB_CODE_OUT_OF_MEMORY;
}