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-07-08 15:32:17 +08:00
parent f40ebe0e40
commit 3d7b4e431e
1 changed files with 0 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/query/src/qExecutor.c
View File

@ -5366,16 +5366,9 @@ static SSDataBlock* doIntervalAgg(void* param, bool* newgroup) {
SOperatorInfo* upstream = pOperator->upstream[0]; SOperatorInfo* upstream = pOperator->upstream[0];
int64_t ss = taosGetTimestampMs();
printf("=-=============%ld\n", ss);
while(1) { while(1) {
publishOperatorProfEvent(upstream, QUERY_PROF_BEFORE_OPERATOR_EXEC); publishOperatorProfEvent(upstream, QUERY_PROF_BEFORE_OPERATOR_EXEC);
int64_t s = taosGetTimestampMs();
printf("start: %ld\n", s);
SSDataBlock* pBlock = upstream->exec(upstream, newgroup); SSDataBlock* pBlock = upstream->exec(upstream, newgroup);
int64_t end = taosGetTimestampMs();
printf("end: %ld, el:%ld \n", end, end - s);
publishOperatorProfEvent(upstream, QUERY_PROF_AFTER_OPERATOR_EXEC); publishOperatorProfEvent(upstream, QUERY_PROF_AFTER_OPERATOR_EXEC);
if (pBlock == NULL) { if (pBlock == NULL) {
@ -5384,16 +5377,9 @@ static SSDataBlock* doIntervalAgg(void* param, bool* newgroup) {
// the pDataBlock are always the same one, no need to call this again // the pDataBlock are always the same one, no need to call this again
setInputDataBlock(pOperator, pIntervalInfo->pCtx, pBlock, pQueryAttr->order.order); setInputDataBlock(pOperator, pIntervalInfo->pCtx, pBlock, pQueryAttr->order.order);
int64_t x1 = taosGetTimestampMs();
hashIntervalAgg(pOperator, &pIntervalInfo->resultRowInfo, pBlock, 0); hashIntervalAgg(pOperator, &pIntervalInfo->resultRowInfo, pBlock, 0);
int64_t x2 = taosGetTimestampMs();
printf("-------------------------inter:%ld\n", x2-x1);
} }
int64_t s1 = taosGetTimestampMs();
printf("=-=============%ld, el:%ld\n", s1, s1-ss);
// restore the value // restore the value
pQueryAttr->order.order = order; pQueryAttr->order.order = order;
pQueryAttr->window = win; pQueryAttr->window = win;