add hash support for stable filter
This commit is contained in:
parent
963fb9b9f6
commit
b0934caae1
|
@ -873,6 +873,11 @@ bool tqNextDataBlock(STqReadHandle* pHandle) {
|
||||||
pHandle->pBlock->schemaLen = htonl(pHandle->pBlock->schemaLen);
|
pHandle->pBlock->schemaLen = htonl(pHandle->pBlock->schemaLen);
|
||||||
pHandle->pBlock->numOfRows = htons(pHandle->pBlock->numOfRows);
|
pHandle->pBlock->numOfRows = htons(pHandle->pBlock->numOfRows);
|
||||||
return true;
|
return true;
|
||||||
|
} else if (pHandle->tbIdHash != NULL) {
|
||||||
|
void* ret = taosHashGet(pHandle->tbIdHash, &pHandle->pBlock->uid, sizeof(int64_t));
|
||||||
|
if (ret != NULL) {
|
||||||
|
return true;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return false;
|
return false;
|
||||||
|
|
Loading…
Reference in New Issue