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

enh: include

This commit is contained in:
factosea 2024-11-19 16:23:46 +08:00
parent 82b20df9ab
commit f3acf49e22
7 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
source/libs/command/src/explain.c
View File

@ -748,7 +748,7 @@ static int32_t qExplainResNodeToRowsImpl(SExplainResNode *pResNode, SExplainCtx
} }
case QUERY_NODE_PHYSICAL_PLAN_HASH_AGG: { case QUERY_NODE_PHYSICAL_PLAN_HASH_AGG: {
SAggPhysiNode *pAggNode = (SAggPhysiNode *)pNode; SAggPhysiNode *pAggNode = (SAggPhysiNode *)pNode;
EXPLAIN_ROW_NEW(level, EXPLAIN_AGG_FORMAT, (pAggNode->pGroupKeys ? "GroupAggragate" : "Aggragate")); EXPLAIN_ROW_NEW(level, EXPLAIN_AGG_FORMAT, (pAggNode->pGroupKeys ? "GroupAggregate" : "Aggregate"));
EXPLAIN_ROW_APPEND(EXPLAIN_LEFT_PARENTHESIS_FORMAT); EXPLAIN_ROW_APPEND(EXPLAIN_LEFT_PARENTHESIS_FORMAT);
if (pResNode->pExecInfo) { if (pResNode->pExecInfo) {
QRY_ERR_RET(qExplainBufAppendExecInfo(pResNode->pExecInfo, tbuf, &tlen)); QRY_ERR_RET(qExplainBufAppendExecInfo(pResNode->pExecInfo, tbuf, &tlen));

1
source/libs/executor/inc/dynqueryctrl.h
View File

@ -19,6 +19,7 @@
extern "C" { extern "C" {
#endif #endif
#include "executorInt.h"
typedef struct SDynQueryCtrlExecInfo { typedef struct SDynQueryCtrlExecInfo {
int64_t prevBlkNum; int64_t prevBlkNum;
int64_t prevBlkRows; int64_t prevBlkRows;

1
source/libs/executor/inc/groupcache.h
View File

@ -18,6 +18,7 @@
#ifdef __cplusplus #ifdef __cplusplus
extern "C" { extern "C" {
#endif #endif
#include "executorInt.h"
#define GROUP_CACHE_DEFAULT_MAX_FILE_SIZE 104857600 #define GROUP_CACHE_DEFAULT_MAX_FILE_SIZE 104857600
#define GROUP_CACHE_MAX_FILE_FDS 10 #define GROUP_CACHE_MAX_FILE_FDS 10

3
source/libs/executor/inc/hashjoin.h
View File

@ -19,6 +19,9 @@
extern "C" { extern "C" {
#endif #endif
#include "executorInt.h"
#include "operator.h"
#define HASH_JOIN_DEFAULT_PAGE_SIZE 10485760 #define HASH_JOIN_DEFAULT_PAGE_SIZE 10485760
#define HJOIN_DEFAULT_BLK_ROWS_NUM 4096 #define HJOIN_DEFAULT_BLK_ROWS_NUM 4096
#define HJOIN_BLK_SIZE_LIMIT 10485760 #define HJOIN_BLK_SIZE_LIMIT 10485760

1
source/libs/executor/inc/operator.h
View File

@ -20,6 +20,7 @@
extern "C" { extern "C" {
#endif #endif
#include "executorInt.h"
typedef struct SOperatorCostInfo { typedef struct SOperatorCostInfo {
double openCost; double openCost;
double totalCost; double totalCost;

2
source/libs/executor/inc/querytask.h
View File

@ -20,6 +20,8 @@
extern "C" { extern "C" {
#endif #endif
#include "executorInt.h"
#define GET_TASKID(_t) (((SExecTaskInfo*)(_t))->id.str) #define GET_TASKID(_t) (((SExecTaskInfo*)(_t))->id.str)
enum { enum {

2
source/util/src/tcompare.c
View File

@ -1294,7 +1294,7 @@ void DestroyRegexCache(){
uInfo("[regex cache] destory regex cache"); uInfo("[regex cache] destory regex cache");
bool ret = taosTmrStopA(&sRegexCache.timer); bool ret = taosTmrStopA(&sRegexCache.timer);
if (!ret) { if (!ret) {
uError("failed to stop regex cache timer"); uInfo("stop regex cache timer may be failed");
} }
taosWLockLatch(&sRegexCache.mutex); taosWLockLatch(&sRegexCache.mutex);
sRegexCache.exit = true; sRegexCache.exit = true;