update fst core struct

source/libs/index/inc/index_fst.h

@@ -255,4 +255,8 @@ FstType      fstGetType(Fst *fst);
 CompiledAddr fstGetRootAddr(Fst *fst);
 Output fstEmptyFinalOutput(Fst *fst, bool *null);
 bool fstVerify(Fst *fst);
+
+
+//refactor this function 
+bool fstBuilderNodeCompileTo(FstBuilderNode *b, FstCountingWriter *wrt, CompiledAddr lastAddr, CompiledAddr startAddr); 
 #endif

source/libs/index/inc/index_fst_node.h

@@ -41,7 +41,7 @@ FstBuilderNode *fstBuilderNodeClone(FstBuilderNode *src);
 
 void fstBuilderNodeCloneFrom(FstBuilderNode *dst, FstBuilderNode *src);
 
-bool fstBuilderNodeCompileTo(FstBuilderNode *b, FstCountingWriter *wrt, CompiledAddr lastAddr, CompiledAddr startAddr); 
+//bool fstBuilderNodeCompileTo(FstBuilderNode *b, FstCountingWriter *wrt, CompiledAddr lastAddr, CompiledAddr startAddr); 
 
 void fstBuilderNodeDestroy(FstBuilderNode *node);
 

source/libs/index/src/index_fst.c

@@ -733,6 +733,11 @@ bool fstNodeCompile(FstNode *node, void *w, CompiledAddr lastAddr, CompiledAddr
   return true; 
 } 
 
+bool fstBuilderNodeCompileTo(FstBuilderNode *b, FstCountingWriter *wrt, CompiledAddr lastAddr, CompiledAddr startAddr) {
+  return fstNodeCompile(NULL, wrt, lastAddr, startAddr, b);
+}
+
+
 
 FstBuilder *fstBuilderCreate(void *w, FstType ty) {
   FstBuilder *b = malloc(sizeof(FstBuilder));  

source/libs/index/src/index_fst_node.c

@@ -59,26 +59,27 @@ void fstBuilderNodeCloneFrom(FstBuilderNode *dst, FstBuilderNode *src) {
   src->trans = NULL;
 }
 
-bool fstBuilderNodeCompileTo(FstBuilderNode *b, FstCountingWriter *wrt, CompiledAddr lastAddr, CompiledAddr startAddr) {
-  size_t sz = taosArrayGetSize(b->trans);  
-  assert(sz < 256);
-  if (FST_BUILDER_NODE_IS_FINAL(b) 
-      && FST_BUILDER_NODE_TRANS_ISEMPTY(b) 
-      && FST_BUILDER_NODE_FINALOUTPUT_ISZERO(b)) {
-    return true; 
-  } else if (sz != 1 || b->isFinal) {
-    // AnyTrans->Compile(w, addr, node);
-  } else {
-    FstTransition *tran = taosArrayGet(b->trans, 0);   
-    if (tran->addr == lastAddr && tran->out == 0) {
-       //OneTransNext::compile(w, lastAddr, tran->inp);
-       return true;
-    } else {
-      //OneTrans::Compile(w, lastAddr, *tran);
-       return true;
-    } 
-  } 
-  return true; 
-} 
+//bool fstBuilderNodeCompileTo(FstBuilderNode *b, FstCountingWriter *wrt, CompiledAddr lastAddr, CompiledAddr startAddr) {
+  
+  //size_t sz = taosArrayGetSize(b->trans);  
+  //assert(sz < 256);
+  //if (FST_BUILDER_NODE_IS_FINAL(b) 
+  //    && FST_BUILDER_NODE_TRANS_ISEMPTY(b) 
+  //    && FST_BUILDER_NODE_FINALOUTPUT_ISZERO(b)) {
+  //  return true; 
+  //} else if (sz != 1 || b->isFinal) {
+  //  // AnyTrans->Compile(w, addr, node);
+  //} else {
+  //  FstTransition *tran = taosArrayGet(b->trans, 0);   
+  //  if (tran->addr == lastAddr && tran->out == 0) {
+  //     //OneTransNext::compile(w, lastAddr, tran->inp);
+  //     return true;
+  //  } else {
+  //    //OneTrans::Compile(w, lastAddr, *tran);
+  //     return true;
+  //  } 
+  //} 
+  //return true; 
+//}