diff --git a/include/common/tmsg.h b/include/common/tmsg.h index 17a4d4ad2c..6bb5406bba 100644 --- a/include/common/tmsg.h +++ b/include/common/tmsg.h @@ -1271,6 +1271,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);