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

remove udfd agg function handling

This commit is contained in:
Ganlin Zhao 2023-07-06 16:11:41 +08:00
parent 19d4c79ac6
commit f7608ce92d
1 changed files with 5 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
source/libs/executor/src/projectoperator.c
View File

@ -632,27 +632,9 @@ int32_t doGenerateSourceData(SOperatorInfo* pOperator) {
} else if (pExpr[k].pExpr->nodeType == QUERY_NODE_FUNCTION) { } else if (pExpr[k].pExpr->nodeType == QUERY_NODE_FUNCTION) {
SqlFunctionCtx* pfCtx = &pSup->pCtx[k]; SqlFunctionCtx* pfCtx = &pSup->pCtx[k];
if (fmIsAggFunc(pfCtx->functionId)) { // UDF scalar functions will be calculated here, for example, select foo(n) from (select 1 n).
// selective value output should be set during corresponding function execution // UDF aggregate functions will be handled in agg operator.
if (fmIsSelectValueFunc(pfCtx->functionId)) { if (fmIsScalarFunc(pfCtx->functionId)) {
continue;
}
SColumnInfoData* pOutput = taosArrayGet(pRes->pDataBlock, outputSlotId);
int32_t slotId = pfCtx->param[0].pCol->slotId;
// todo handle the json tag
//SColumnInfoData* pInput = taosArrayGet(pSrcBlock->pDataBlock, slotId);
//for (int32_t f = 0; f < pSrcBlock->info.rows; ++f) {
// bool isNull = colDataIsNull_s(pInput, f);
// if (isNull) {
// colDataSetNULL(pOutput, pRes->info.rows + f);
// } else {
// char* data = colDataGetData(pInput, f);
// colDataSetVal(pOutput, pRes->info.rows + f, data, isNull);
// }
//}
} else {
SArray* pBlockList = taosArrayInit(4, POINTER_BYTES); SArray* pBlockList = taosArrayInit(4, POINTER_BYTES);
taosArrayPush(pBlockList, &pRes); taosArrayPush(pBlockList, &pRes);
@ -672,6 +654,8 @@ int32_t doGenerateSourceData(SOperatorInfo* pOperator) {
colDataDestroy(&idata); colDataDestroy(&idata);
taosArrayDestroy(pBlockList); taosArrayDestroy(pBlockList);
} else {
return TSDB_CODE_OPS_NOT_SUPPORT;
} }
} else { } else {
return TSDB_CODE_OPS_NOT_SUPPORT; return TSDB_CODE_OPS_NOT_SUPPORT;