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

feat: add multiple group tsdb reads to table merge scan

This commit is contained in:
shenglian zhou 2022-06-22 22:00:52 +08:00
parent df130c1bcb
commit c99f7cac79
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
source/libs/executor/src/scanoperator.c
View File

@ -2212,15 +2212,17 @@ int32_t startGroupTableMergeScan(SOperatorInfo* pOperator) {
STableMergeScanInfo* pInfo = pOperator->info; STableMergeScanInfo* pInfo = pOperator->info;
SExecTaskInfo* pTaskInfo = pOperator->pTaskInfo; SExecTaskInfo* pTaskInfo = pOperator->pTaskInfo;
size_t tableListSize = taosArrayGetSize(pInfo->tableListInfo->pTableList); {
int32_t i = pInfo->tableStartIndex + 1; size_t tableListSize = taosArrayGetSize(pInfo->tableListInfo->pTableList);
for (; i < tableListSize; ++i) { int32_t i = pInfo->tableStartIndex + 1;
STableKeyInfo* tableKeyInfo = taosArrayGet(pInfo->tableListInfo->pTableList, i); for (; i < tableListSize; ++i) {
if (tableKeyInfo->groupId != pInfo->groupId) { STableKeyInfo* tableKeyInfo = taosArrayGet(pInfo->tableListInfo->pTableList, i);
break; if (tableKeyInfo->groupId != pInfo->groupId) {
break;
}
} }
pInfo->tableEndIndex = i - 1;
} }
pInfo->tableEndIndex = i - 1;
int32_t tableStartIdx = pInfo->tableStartIndex; int32_t tableStartIdx = pInfo->tableStartIndex;
int32_t tableEndIdx = pInfo->tableEndIndex; int32_t tableEndIdx = pInfo->tableEndIndex;