refactor: do some internal refactor.

This commit is contained in:
Haojun Liao 2023-04-25 09:54:00 +08:00
parent ae8a9d25c0
commit e724bc15e0
1 changed files with 2 additions and 2 deletions

View File

@ -2567,8 +2567,8 @@ static bool initLastBlockReader(SLastBlockReader* pLBlockReader, STableBlockScan
}
static int64_t getCurrentKeyInLastBlock(SLastBlockReader* pLastBlockReader) {
TSDBROW row = tMergeTreeGetRow(&pLastBlockReader->mergeTree);
return TSDBROW_TS(&row);
TSDBROW* pRow = &tMergeTreeGetRow((&(pLastBlockReader)->mergeTree));
return pRow->pBlockData->aTSKEY[pRow->iRow];
}
static bool hasDataInLastBlock(SLastBlockReader* pLastBlockReader) { return pLastBlockReader->mergeTree.pIter != NULL; }