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

[td-225]fix compiler error.

This commit is contained in:
Haojun Liao 2021-04-25 22:18:56 +08:00
parent b87add1b58
commit 97ee48779c
2 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/client/src/tscServer.c
View File

@ -1013,7 +1013,7 @@ int tscBuildQueryMsg(SSqlObj *pSql, SSqlInfo *pInfo) {
pQueryMsg->tsBuf.tsNumOfBlocks = htonl(pQueryMsg->tsBuf.tsNumOfBlocks); pQueryMsg->tsBuf.tsNumOfBlocks = htonl(pQueryMsg->tsBuf.tsNumOfBlocks);
} }
int32_t numOfOperator = taosArrayGetSize(queryOperator); int32_t numOfOperator = (int32_t) taosArrayGetSize(queryOperator);
pQueryMsg->numOfOperator = htonl(numOfOperator); pQueryMsg->numOfOperator = htonl(numOfOperator);
for(int32_t i = 0; i < numOfOperator; ++i) { for(int32_t i = 0; i < numOfOperator; ++i) {
int32_t *operator = taosArrayGet(queryOperator, i); int32_t *operator = taosArrayGet(queryOperator, i);

11
src/query/src/qPlan.c
View File

@ -16,11 +16,18 @@
#define QNODE_TIMEWINDOW 11 #define QNODE_TIMEWINDOW 11
typedef struct SQueryNode { typedef struct SQueryNode {
int32_t type; int32_t type; // the type of logic node
char *name; // the name of logic node
SSchema *pSchema; // the schema of the input SSDatablock
int32_t numOfCols; // number of input columns
SExprInfo *pExpr; // the query functions or sql aggregations
int32_t numOfOutput; // number of result columns, which is also the number of pExprs
// previous operator to generated result for current node to process // previous operator to generated result for current node to process
// in case of join, multiple prev nodes exist. // in case of join, multiple prev nodes exist.
struct SQueryNode* prevNode; struct SQueryNode* prevNode;
struct SQueryNode* nextNode;
} SQueryNode; } SQueryNode;
// TODO create the query plan // TODO create the query plan