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

remove set null in tsdbread

This commit is contained in:
Liu Jicong 2021-08-09 05:19:22 +08:00
parent 855a76813c
commit 1d3a2d47f1
1 changed files with 9 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/tsdb/src/tsdbReadImpl.c
View File

@ -464,8 +464,9 @@ static int tsdbLoadBlockDataImpl(SReadH *pReadh, SBlock *pBlock, SDataCols *pDat
if (dcol != 0 && ccol >= pBlockData->numOfCols) { if (dcol != 0 && ccol >= pBlockData->numOfCols) {
// Set current column as NULL and forward // Set current column as NULL and forward
// TODO: tdAllocMemForCol may fail // TODO: tdAllocMemForCol may fail
tdAllocMemForCol(pDataCol, pDataCols->maxPoints); /*tdAllocMemForCol(pDataCol, pDataCols->maxPoints);*/
dataColSetNEleNull(pDataCol, pBlock->numOfRows); /*dataColSetNEleNull(pDataCol, pBlock->numOfRows);*/
dataColReset(pDataCol);
dcol++; dcol++;
continue; continue;
} }
@ -506,8 +507,9 @@ static int tsdbLoadBlockDataImpl(SReadH *pReadh, SBlock *pBlock, SDataCols *pDat
} else { } else {
// Set current column as NULL and forward // Set current column as NULL and forward
// TODO: tdAllocMemForCol may fail // TODO: tdAllocMemForCol may fail
tdAllocMemForCol(pDataCol, pDataCols->maxPoints); /*tdAllocMemForCol(pDataCol, pDataCols->maxPoints);*/
dataColSetNEleNull(pDataCol, pBlock->numOfRows); /*dataColSetNEleNull(pDataCol, pBlock->numOfRows);*/
dataColReset(pDataCol);
dcol++; dcol++;
} }
} }
@ -613,8 +615,9 @@ static int tsdbLoadBlockDataColsImpl(SReadH *pReadh, SBlock *pBlock, SDataCols *
if (pBlockCol == NULL) { if (pBlockCol == NULL) {
// TODO: tdAllocMemForCol may fail // TODO: tdAllocMemForCol may fail
tdAllocMemForCol(pDataCol, pDataCols->maxPoints); /*tdAllocMemForCol(pDataCol, pDataCols->maxPoints);*/
dataColSetNEleNull(pDataCol, pBlock->numOfRows); /*dataColSetNEleNull(pDataCol, pBlock->numOfRows);*/
dataColReset(pDataCol);
continue; continue;
} }