more work
This commit is contained in:
parent
553f1bd506
commit
0dbdc3d68e
|
@ -647,15 +647,11 @@ void tsdbRowGetColVal(TSDBROW *pRow, STSchema *pTSchema, int32_t iCol, SColVal *
|
||||||
if (pRow->type == 0) {
|
if (pRow->type == 0) {
|
||||||
tTSRowGetVal(pRow->pTSRow, pTSchema, iCol, pColVal);
|
tTSRowGetVal(pRow->pTSRow, pTSchema, iCol, pColVal);
|
||||||
} else if (pRow->type == 1) {
|
} else if (pRow->type == 1) {
|
||||||
SColData *pColData = &(SColData){.cid = pTColumn->colId};
|
SColData *pColData;
|
||||||
void *p = NULL;
|
|
||||||
|
|
||||||
p = taosArraySearch(pRow->pBlockData->aColDataP, &pColData, tColDataPCmprFn, TD_EQ);
|
tBlockDataGetColData(pRow->pBlockData, pTColumn->colId, &pColData);
|
||||||
if (p) {
|
|
||||||
pColData = *(SColData **)p;
|
|
||||||
|
|
||||||
ASSERT(pColData->type == pTColumn->type);
|
|
||||||
|
|
||||||
|
if (pColData) {
|
||||||
tColDataGetValue(pColData, pRow->iRow, pColVal);
|
tColDataGetValue(pColData, pRow->iRow, pColVal);
|
||||||
} else {
|
} else {
|
||||||
*pColVal = COL_VAL_NONE(pTColumn->colId, pTColumn->type);
|
*pColVal = COL_VAL_NONE(pTColumn->colId, pTColumn->type);
|
||||||
|
|
Loading…
Reference in New Issue