diff --git a/include/common/tmsg.h b/include/common/tmsg.h index 0b7ba24c6b..5cf027591f 100644 --- a/include/common/tmsg.h +++ b/include/common/tmsg.h @@ -23,6 +23,7 @@ extern "C" { #include "encode.h" #include "taosdef.h" #include "taoserror.h" +#include "tarray.h" #include "tcoding.h" #include "tdataformat.h" #include "tlist.h" @@ -1274,6 +1275,11 @@ typedef struct SVCreateTbReq { }; } SVCreateTbReq; +typedef struct { + uint64_t ver; // use a general definition + SArray* pArray; +} SVCreateTbBatchReq; + int tmsgSVCreateTbReqEncode(SMsgEncoder* pCoder, SVCreateTbReq* pReq); int tmsgSVCreateTbReqDecode(SMsgDecoder* pCoder, SVCreateTbReq* pReq); int tSerializeSVCreateTbReq(void** buf, const SVCreateTbReq* pReq); diff --git a/include/dnode/vnode/meta/meta.h b/include/dnode/vnode/meta/meta.h index b75e478add..d587107270 100644 --- a/include/dnode/vnode/meta/meta.h +++ b/include/dnode/vnode/meta/meta.h @@ -59,9 +59,9 @@ STbCfg * metaGetTbInfoByUid(SMeta *pMeta, tb_uid_t uid); STbCfg * metaGetTbInfoByName(SMeta *pMeta, char *tbname, tb_uid_t *uid); SSchemaWrapper *metaGetTableSchema(SMeta *pMeta, tb_uid_t uid, int32_t sver, bool isinline); -SMTbCursor * metaOpenTbCursor(SMeta *pMeta); -void metaCloseTbCursor(SMTbCursor *pTbCur); -char *metaTbCursorNext(SMTbCursor *pTbCur); +SMTbCursor *metaOpenTbCursor(SMeta *pMeta); +void metaCloseTbCursor(SMTbCursor *pTbCur); +char * metaTbCursorNext(SMTbCursor *pTbCur); // Options void metaOptionsInit(SMetaCfg *pMetaCfg);