提交 d11c44fc 编写于 作者: H Haojun Liao

[td-11818] refactor.

上级 c15c88df
...@@ -46,7 +46,7 @@ qTaskInfo_t qCreateStreamExecTaskInfo(void *msg, void* streamReadHandle); ...@@ -46,7 +46,7 @@ qTaskInfo_t qCreateStreamExecTaskInfo(void *msg, void* streamReadHandle);
* @param input * @param input
* @return * @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. * Update the table id list, add or remove.
...@@ -56,7 +56,7 @@ int32_t qSetStreamInput(qTaskInfo_t tinfo, const void* input); ...@@ -56,7 +56,7 @@ int32_t qSetStreamInput(qTaskInfo_t tinfo, const void* input);
* @param isAdd * @param isAdd
* @return * @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 * Create the exec task object according to task json
......
...@@ -91,7 +91,7 @@ qTaskInfo_t qCreateStreamExecTaskInfo(void* msg, void* streamReadHandle) { ...@@ -91,7 +91,7 @@ qTaskInfo_t qCreateStreamExecTaskInfo(void* msg, void* streamReadHandle) {
return pTaskInfo; 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; SExecTaskInfo* pTaskInfo = (SExecTaskInfo* )tinfo;
// traverse to the streamscan node to add this table id // traverse to the streamscan node to add this table id
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册