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

add systable filterr

This commit is contained in:
yihaoDeng 2022-10-13 21:49:53 +08:00
parent 681b973cae
commit 974bc4b7c6
2 changed files with 19 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
source/libs/executor/src/executil.c
View File

@ -421,16 +421,6 @@ static SColumnInfoData* getColInfoResult(void* metaHandle, int64_t suid, SArray*
goto end; goto end;
} }
} }
/*else {
code = metaGetTableTagsByUids(metaHandle, suid, uidList, tags);
if (code != 0) {
terrno = code;
qError("failed to get table from meta idx, reason: %s, suid:%" PRId64, tstrerror(code), suid);
goto end;
} else {
qInfo("succ to get table from meta idx, suid:%" PRId64, suid);
}
}*/
int32_t rows = taosArrayGetSize(uidList); int32_t rows = taosArrayGetSize(uidList);
if (rows == 0) { if (rows == 0) {

19
source/libs/executor/src/scanoperator.c
View File

@ -2724,9 +2724,28 @@ static int32_t sysTableUserTagsFillOneTableTags(const SSysTableScanInfo* pInfo,
return TSDB_CODE_SUCCESS; return TSDB_CODE_SUCCESS;
} }
static char* SYSTABLE_IDX_COLUMN[] = {"table_name", "db_name", "create_time", "columns",
"ttl", "stable_name", "vgroup_id', 'uid", "type"};
typedef int32_t (*__sys_filter)(void* pMeta, SNode* condition, SArray* result);
typedef struct {
const char* name;
__sys_filter fltFunc;
} SSTabFltFuncDef;
const SSTabFltFuncDef filterDict[] = {
{.name = "table_name", .fltFunc = NULL}, {.name = "db_name", .fltFunc = NULL},
{.name = "create_time", .fltFunc = NULL}, {.name = "columns", .fltFunc = NULL},
{.name = "ttl", .fltFunc = NULL}, {.name = "stable_name", .fltFunc = NULL},
{.name = "vgroup_id", .fltFunc = NULL}, {.name = "uid", .fltFunc = NULL},
{.name = "type", .fltFunc = NULL}};
static SSDataBlock* sysTableScanUserTables(SOperatorInfo* pOperator) { static SSDataBlock* sysTableScanUserTables(SOperatorInfo* pOperator) {
SExecTaskInfo* pTaskInfo = pOperator->pTaskInfo; SExecTaskInfo* pTaskInfo = pOperator->pTaskInfo;
SSysTableScanInfo* pInfo = pOperator->info; SSysTableScanInfo* pInfo = pOperator->info;
SNode* pCondtion = pInfo->pCondition;
if (pOperator->status == OP_EXEC_DONE) { if (pOperator->status == OP_EXEC_DONE) {
return NULL; return NULL;
} }