From d11c44fc184be45d4479986a47b1018203d98373 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Thu, 17 Feb 2022 18:38:55 +0800 Subject: [PATCH] [td-11818] refactor. --- include/libs/executor/executor.h | 4 ++-- source/libs/executor/src/executor.c | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/include/libs/executor/executor.h b/include/libs/executor/executor.h index caa8f0bc36..4d53f40176 100644 --- a/include/libs/executor/executor.h +++ b/include/libs/executor/executor.h @@ -46,7 +46,7 @@ qTaskInfo_t qCreateStreamExecTaskInfo(void *msg, void* streamReadHandle); * @param input * @return */ -int32_t qSetStreamInput(qTaskInfo_t tinfo, const void* input); +int32_t qSetStreamInput(qTaskInfo_t tinfo, const void* input); /** * Update the table id list, add or remove. @@ -56,7 +56,7 @@ int32_t qSetStreamInput(qTaskInfo_t tinfo, const void* input); * @param isAdd * @return */ -int32_t qUpdateTQualifiedTableId(qTaskInfo_t tinfo, SArray* tableIdList, bool isAdd); +int32_t qUpdateQualifiedTableId(qTaskInfo_t tinfo, SArray* tableIdList, bool isAdd); /** * Create the exec task object according to task json diff --git a/source/libs/executor/src/executor.c b/source/libs/executor/src/executor.c index 29e60c8e91..e7e6dd7129 100644 --- a/source/libs/executor/src/executor.c +++ b/source/libs/executor/src/executor.c @@ -91,7 +91,7 @@ qTaskInfo_t qCreateStreamExecTaskInfo(void* msg, void* streamReadHandle) { return pTaskInfo; } -int32_t qUpdateTQualifiedTableId(qTaskInfo_t tinfo, SArray* tableIdList, bool isAdd) { +int32_t qUpdateQualifiedTableId(qTaskInfo_t tinfo, SArray* tableIdList, bool isAdd) { SExecTaskInfo* pTaskInfo = (SExecTaskInfo* )tinfo; // traverse to the streamscan node to add this table id