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

more code

This commit is contained in:
Hongze Cheng 2022-08-24 11:51:34 +08:00
parent f696ef0a6a
commit 1c182684c4
1 changed files with 0 additions and 48 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
source/dnode/vnode/src/tsdb/tsdbCommit.c
View File

@ -327,54 +327,6 @@ _exit:
return code;
}
// static int32_t tsdbCommitterNextLastRow(SCommitter *pCommitter) {
// int32_t code = 0;
// ASSERT(pCommitter->dReader.pReader);
// ASSERT(pCommitter->dReader.pRowInfo);
// SBlockData *pBlockDatal = &pCommitter->dReader.bDatal;
// pCommitter->dReader.iRow++;
// if (pCommitter->dReader.iRow < pBlockDatal->nRow) {
// if (pBlockDatal->uid) {
// pCommitter->dReader.pRowInfo->uid = pBlockDatal->uid;
// } else {
// pCommitter->dReader.pRowInfo->uid = pBlockDatal->aUid[pCommitter->dReader.iRow];
// }
// pCommitter->dReader.pRowInfo->row = tsdbRowFromBlockData(pBlockDatal, pCommitter->dReader.iRow);
// } else {
// pCommitter->dReader.iBlockL++;
// if (pCommitter->dReader.iBlockL < taosArrayGetSize(pCommitter->dReader.aBlockL)) {
// SBlockL *pBlockL = (SBlockL *)taosArrayGet(pCommitter->dReader.aBlockL, pCommitter->dReader.iBlockL);
// int64_t suid = pBlockL->suid;
// int64_t uid = pBlockL->maxUid;
// code = tsdbCommitterUpdateTableSchema(pCommitter, suid, uid);
// if (code) goto _exit;
// code = tBlockDataInit(pBlockDatal, suid, suid ? 0 : uid, pCommitter->skmTable.pTSchema);
// if (code) goto _exit;
// code = tsdbReadLastBlock(pCommitter->dReader.pReader, pBlockL, pBlockDatal);
// if (code) goto _exit;
// pCommitter->dReader.iRow = 0;
// pCommitter->dReader.pRowInfo->suid = pBlockDatal->suid;
// if (pBlockDatal->uid) {
// pCommitter->dReader.pRowInfo->uid = pBlockDatal->uid;
// } else {
// pCommitter->dReader.pRowInfo->uid = pBlockDatal->aUid[0];
// }
// pCommitter->dReader.pRowInfo->row = tsdbRowFromBlockData(pBlockDatal, pCommitter->dReader.iRow);
// } else {
// pCommitter->dReader.pRowInfo = NULL;
// }
// }
// _exit:
// return code;
// }
static int32_t tsdbCommitterNextTableData(SCommitter *pCommitter) {
int32_t code = 0;