Implemented add and serialize

Former-commit-id: f07f8c4f02370e6b5567b8f3385601b5c2c9fe50

cpp/src/db/MemTableFile.cpp

@@ -103,6 +103,32 @@ Status MemTableFile::Serialize() {
     return status;
 }
 
+Status MemTableFile::Serialize() {
+
+    auto start_time = METRICS_NOW_TIME;
+
+    auto size = GetCurrentMem();
+
+    execution_engine_->Serialize();
+    auto end_time = METRICS_NOW_TIME;
+    auto total_time = METRICS_MICROSECONDS(start_time, end_time);
+    table_file_schema_.size_ = size;
+
+    server::Metrics::GetInstance().DiskStoreIOSpeedGaugeSet((double)size/total_time);
+
+    table_file_schema_.file_type_ = (size >= options_.index_trigger_size) ?
+                         meta::TableFileSchema::TO_INDEX : meta::TableFileSchema::RAW;
+
+    auto status = meta_->UpdateTableFile(table_file_schema_);
+
+    LOG(DEBUG) << "New " << ((table_file_schema_.file_type_ == meta::TableFileSchema::RAW) ? "raw" : "to_index")
+               << " file " << table_file_schema_.file_id_ << " of size " << (double)size / (double)M << " M";
+
+    execution_engine_->Cache();
+
+    return status;
+}
+
 } // namespace engine
 } // namespace milvus
 } // namespace zilliz
\ No newline at end of file

cpp/src/db/VectorSource.cpp

@@ -4,7 +4,6 @@
 #include "Log.h"
 #include "metrics/Metrics.h"
 
-
 namespace zilliz {
 namespace milvus {
 namespace engine {

cpp/unittest/db/mem_test.cpp

@@ -146,11 +146,7 @@ TEST_F(NewMemManagerTest, MEM_TABLE_TEST) {
 
     engine::VectorSource::Ptr source_100 = std::make_shared<engine::VectorSource>(n_100, vectors_100.data());
 
-    engine::MemTable mem_table(TABLE_NAME, impl_, options);
-
-    status = mem_table.Add(source_100);
     ASSERT_TRUE(status.ok());
-
     engine::IDNumbers vector_ids = source_100->GetVectorIds();
     ASSERT_EQ(vector_ids.size(), 100);
 
@@ -193,6 +189,9 @@ TEST_F(NewMemManagerTest, MEM_TABLE_TEST) {
     status = mem_table.Serialize();
     ASSERT_TRUE(status.ok());
 
+    status = memTable.Serialize();
+    ASSERT_TRUE(status.ok());
+
     status = impl_->DropAll();
     ASSERT_TRUE(status.ok());
 }