update business_cpp output

ncbd · Sep 6, 2024 · d3606fd · d3606fd
1 parent 27bc695
commit d3606fd
Show file tree

Hide file tree

Showing 123 changed files with 503 additions and 476 deletions.
diff --git a/include/lgraph/olap_on_db.h b/include/lgraph/olap_on_db.h
@@ -1503,6 +1503,39 @@ class OlapOnDB : public OlapBase<EdgeData> {
         }
     }
 
+    /**
+     * @brief    Write vertex data to a file.
+     *
+     * @param    vertex_data    The parallel vector storing the vertex data.
+     * @param    output_file    The path to the output file.
+     *
+     */
+    template <typename VertexData>
+    void WriteToFile(bool detail_output, ParallelVector<VertexData> &vertex_data,
+                     const std::string &output_file,
+                     std::function<bool(size_t vid, VertexData &vdata)> output_filter = nullptr) {
+        FILE* fout = fopen(output_file.c_str(), "w");
+        if (fout == nullptr) {
+            THROW_CODE(InputError, "Unable to open file for writting!");
+        }
+        for (size_t i = 0; i < this->num_vertices_; ++i) {
+            if (output_filter != nullptr && !output_filter(i, vertex_data[i])) {
+                continue;
+            }
+            auto vit = txn_.GetVertexIterator(OriginalVid(i));
+            auto vit_label = vit.GetLabel();
+            auto primary_field = txn_.GetVertexPrimaryField(vit_label);
+            auto field_data = vit.GetField(primary_field);
+            json curJson;
+            curJson["vid"] = OriginalVid(i);
+            curJson["label"] = vit_label;
+            curJson["primary_field"] = primary_field;
+            curJson["field_data"] = field_data.ToString();
+            curJson["result"] = vertex_data[i];
+            fprintf(fout, "%s\n", curJson.dump().c_str());
+        }
+    }
+
     /**
      * @brief    Write vertex data to the graph database.
      *

diff --git a/procedures/business_cpp/algo_cpp/algo.h → procedures/business_cpp/algo.h b/procedures/business_cpp/algo_cpp/algo.h → procedures/business_cpp/algo.h
diff --git a/...dures/business_cpp/algo_cpp/apsp_core.cpp → procedures/business_cpp/apsp_core.cpp b/...dures/business_cpp/algo_cpp/apsp_core.cpp → procedures/business_cpp/apsp_core.cpp
diff --git a/.../business_cpp/algo_cpp/apsp_procedure.cpp → procedures/business_cpp/apsp_procedure.cpp b/.../business_cpp/algo_cpp/apsp_procedure.cpp → procedures/business_cpp/apsp_procedure.cpp
diff --git a/...business_cpp/algo_cpp/apsp_standalone.cpp → procedures/business_cpp/apsp_standalone.cpp b/...business_cpp/algo_cpp/apsp_standalone.cpp → procedures/business_cpp/apsp_standalone.cpp
diff --git a/procedures/business_cpp/algo_cpp/bc_core.cpp → procedures/business_cpp/bc_core.cpp b/procedures/business_cpp/algo_cpp/bc_core.cpp → procedures/business_cpp/bc_core.cpp
diff --git a/...es/business_cpp/algo_cpp/bc_procedure.cpp → procedures/business_cpp/bc_procedure.cpp b/...es/business_cpp/algo_cpp/bc_procedure.cpp → procedures/business_cpp/bc_procedure.cpp
@@ -54,7 +54,7 @@ extern "C" bool Process(GraphDB& db, const std::string& request, std::string& re
     // output
     start_time = get_time();
     if (output_file != "") {
-        olapondb.WriteToFile(score, output_file);
+        olapondb.WriteToFile(true, score, output_file);
     }
     auto output_cost = get_time() - start_time;
 

diff --git a/...s/business_cpp/algo_cpp/bc_standalone.cpp → procedures/business_cpp/bc_standalone.cpp b/...s/business_cpp/algo_cpp/bc_standalone.cpp → procedures/business_cpp/bc_standalone.cpp
diff --git a/...edures/business_cpp/algo_cpp/bfs_core.cpp → procedures/business_cpp/bfs_core.cpp b/...edures/business_cpp/algo_cpp/bfs_core.cpp → procedures/business_cpp/bfs_core.cpp
diff --git a/...s/business_cpp/algo_cpp/bfs_procedure.cpp → procedures/business_cpp/bfs_procedure.cpp b/...s/business_cpp/algo_cpp/bfs_procedure.cpp → procedures/business_cpp/bfs_procedure.cpp
@@ -59,7 +59,8 @@ extern "C" bool Process(GraphDB& db, const std::string& request, std::string& re
     start_time = get_time();
     // TODO(any): write parent back to graph
     if (output_file != "") {
-        olapondb.WriteToFile<size_t>(parent, output_file, [&](size_t vid, size_t vdata) -> bool {
+        olapondb.WriteToFile<size_t>(true, parent, output_file,
+                                    [&](size_t vid, size_t vdata) -> bool {
             return vdata != (size_t)-1;
         });
     }

diff --git a/...usiness_cpp/algo_cpp/bfs_procedure_v2.cpp → procedures/business_cpp/bfs_procedure_v2.cpp b/...usiness_cpp/algo_cpp/bfs_procedure_v2.cpp → procedures/business_cpp/bfs_procedure_v2.cpp
diff --git a/.../business_cpp/algo_cpp/bfs_standalone.cpp → procedures/business_cpp/bfs_standalone.cpp b/.../business_cpp/algo_cpp/bfs_standalone.cpp → procedures/business_cpp/bfs_standalone.cpp
diff --git a/...dures/business_cpp/algo_cpp/clce_core.cpp → procedures/business_cpp/clce_core.cpp b/...dures/business_cpp/algo_cpp/clce_core.cpp → procedures/business_cpp/clce_core.cpp
diff --git a/.../business_cpp/algo_cpp/clce_procedure.cpp → procedures/business_cpp/clce_procedure.cpp b/.../business_cpp/algo_cpp/clce_procedure.cpp → procedures/business_cpp/clce_procedure.cpp
@@ -65,7 +65,7 @@ extern "C" bool Process(GraphDB& db, const std::string& request, std::string& re
     // output
     start_time = get_time();
     if (output_file != "") {
-        olapondb.WriteToFile<double>(score, output_file);
+        olapondb.WriteToFile<double>(true, score, output_file);
     }
     auto output_cost = get_time() - start_time;
 

diff --git a/...business_cpp/algo_cpp/clce_standalone.cpp → procedures/business_cpp/clce_standalone.cpp b/...business_cpp/algo_cpp/clce_standalone.cpp → procedures/business_cpp/clce_standalone.cpp
diff --git a/procedures/business_cpp/algo_cpp/cn_core.cpp → procedures/business_cpp/cn_core.cpp b/procedures/business_cpp/algo_cpp/cn_core.cpp → procedures/business_cpp/cn_core.cpp
diff --git a/...es/business_cpp/algo_cpp/cn_procedure.cpp → procedures/business_cpp/cn_procedure.cpp b/...es/business_cpp/algo_cpp/cn_procedure.cpp → procedures/business_cpp/cn_procedure.cpp
diff --git a/...s/business_cpp/algo_cpp/cn_standalone.cpp → procedures/business_cpp/cn_standalone.cpp b/...s/business_cpp/algo_cpp/cn_standalone.cpp → procedures/business_cpp/cn_standalone.cpp
diff --git a/procedures/business_cpp/algo_cpp/dc_core.cpp → procedures/business_cpp/dc_core.cpp b/procedures/business_cpp/algo_cpp/dc_core.cpp → procedures/business_cpp/dc_core.cpp
diff --git a/...es/business_cpp/algo_cpp/dc_procedure.cpp → procedures/business_cpp/dc_procedure.cpp b/...es/business_cpp/algo_cpp/dc_procedure.cpp → procedures/business_cpp/dc_procedure.cpp
diff --git a/...s/business_cpp/algo_cpp/dc_standalone.cpp → procedures/business_cpp/dc_standalone.cpp b/...s/business_cpp/algo_cpp/dc_standalone.cpp → procedures/business_cpp/dc_standalone.cpp
diff --git a/procedures/business_cpp/algo_cpp/de_core.cpp → procedures/business_cpp/de_core.cpp b/procedures/business_cpp/algo_cpp/de_core.cpp → procedures/business_cpp/de_core.cpp
diff --git a/...es/business_cpp/algo_cpp/de_procedure.cpp → procedures/business_cpp/de_procedure.cpp b/...es/business_cpp/algo_cpp/de_procedure.cpp → procedures/business_cpp/de_procedure.cpp
diff --git a/...s/business_cpp/algo_cpp/de_standalone.cpp → procedures/business_cpp/de_standalone.cpp b/...s/business_cpp/algo_cpp/de_standalone.cpp → procedures/business_cpp/de_standalone.cpp
diff --git a/procedures/business_cpp/algo_cpp/en_core.cpp → procedures/business_cpp/en_core.cpp b/procedures/business_cpp/algo_cpp/en_core.cpp → procedures/business_cpp/en_core.cpp
diff --git a/...es/business_cpp/algo_cpp/en_procedure.cpp → procedures/business_cpp/en_procedure.cpp b/...es/business_cpp/algo_cpp/en_procedure.cpp → procedures/business_cpp/en_procedure.cpp
diff --git a/...s/business_cpp/algo_cpp/en_standalone.cpp → procedures/business_cpp/en_standalone.cpp b/...s/business_cpp/algo_cpp/en_standalone.cpp → procedures/business_cpp/en_standalone.cpp
diff --git a/.../algo_cpp/fast_triangle_counting_core.cpp → ...iness_cpp/fast_triangle_counting_core.cpp b/.../algo_cpp/fast_triangle_counting_core.cpp → ...iness_cpp/fast_triangle_counting_core.cpp
diff --git a/..._cpp/fast_triangle_counting_procedure.cpp → ..._cpp/fast_triangle_counting_procedure.cpp b/..._cpp/fast_triangle_counting_procedure.cpp → ..._cpp/fast_triangle_counting_procedure.cpp
diff --git a/...cpp/fast_triangle_counting_standalone.cpp → ...cpp/fast_triangle_counting_standalone.cpp b/...cpp/fast_triangle_counting_standalone.cpp → ...cpp/fast_triangle_counting_standalone.cpp
diff --git a/...s/business_cpp/algo_cpp/feature_float.cpp → procedures/business_cpp/feature_float.cpp b/...s/business_cpp/algo_cpp/feature_float.cpp → procedures/business_cpp/feature_float.cpp
diff --git a/...dures/business_cpp/algo_cpp/hits_core.cpp → procedures/business_cpp/hits_core.cpp b/...dures/business_cpp/algo_cpp/hits_core.cpp → procedures/business_cpp/hits_core.cpp
diff --git a/.../business_cpp/algo_cpp/hits_procedure.cpp → procedures/business_cpp/hits_procedure.cpp b/.../business_cpp/algo_cpp/hits_procedure.cpp → procedures/business_cpp/hits_procedure.cpp
diff --git a/...business_cpp/algo_cpp/hits_standalone.cpp → procedures/business_cpp/hits_standalone.cpp b/...business_cpp/algo_cpp/hits_standalone.cpp → procedures/business_cpp/hits_standalone.cpp
diff --git a/procedures/business_cpp/algo_cpp/ji_core.cpp → procedures/business_cpp/ji_core.cpp b/procedures/business_cpp/algo_cpp/ji_core.cpp → procedures/business_cpp/ji_core.cpp
diff --git a/...es/business_cpp/algo_cpp/ji_procedure.cpp → procedures/business_cpp/ji_procedure.cpp b/...es/business_cpp/algo_cpp/ji_procedure.cpp → procedures/business_cpp/ji_procedure.cpp
@@ -58,7 +58,8 @@ extern "C" bool Process(GraphDB& db, const std::string& request, std::string& re
 
     // core
     start_time = get_time();
-    std::vector<std::tuple<std::string, std::string, double>> result_list;
+        std::vector< std::tuple<size_t, std::string, std::string, std::string,
+                        size_t, std::string, std::string, std::string, double> > result_list;
 
     for (auto search_pair : search_list) {
         auto src_string = search_pair.first;
@@ -69,7 +70,24 @@ extern "C" bool Process(GraphDB& db, const std::string& request, std::string& re
             txn.GetVertexIndexIterator(dst_label, dst_field, dst_string, dst_string).GetVid();
         auto id_pair = std::make_pair(src_vid, dst_vid);
         double score = JiCore(olapondb, id_pair);
-        result_list.push_back(std::make_tuple(src_string, dst_string, score));
+
+        auto vit_first = txn.GetVertexIterator(src_vid, false);
+        auto vit_first_label = vit_first.GetLabel();
+        auto vit_first_primary_field = txn.GetVertexPrimaryField(vit_first_label);
+        auto vit_first_field_data = vit_first.GetField(vit_first_primary_field);
+        auto vit_second = txn.GetVertexIterator(dst_vid, false);
+        auto vit_second_label = vit_second.GetLabel();
+        auto vit_second_primary_field = txn.GetVertexPrimaryField(vit_second_label);
+        auto vit_second_field_data = vit_second.GetField(vit_second_primary_field);
+        result_list.push_back(std::make_tuple(src_vid,
+                                                vit_first_label,
+                                                vit_first_primary_field,
+                                                vit_first_field_data.ToString(),
+                                                dst_vid,
+                                                vit_second_label,
+                                                vit_second_primary_field,
+                                                vit_second_field_data.ToString(),
+                                                score));
     }
 
     auto core_cost = get_time() - start_time;

diff --git a/...s/business_cpp/algo_cpp/ji_standalone.cpp → procedures/business_cpp/ji_standalone.cpp b/...s/business_cpp/algo_cpp/ji_standalone.cpp → procedures/business_cpp/ji_standalone.cpp
diff --git a/...s/business_cpp/algo_cpp/kcliques_core.cpp → procedures/business_cpp/kcliques_core.cpp b/...s/business_cpp/algo_cpp/kcliques_core.cpp → procedures/business_cpp/kcliques_core.cpp
diff --git a/...iness_cpp/algo_cpp/kcliques_procedure.cpp → ...dures/business_cpp/kcliques_procedure.cpp b/...iness_cpp/algo_cpp/kcliques_procedure.cpp → ...dures/business_cpp/kcliques_procedure.cpp
diff --git a/...ness_cpp/algo_cpp/kcliques_standalone.cpp → ...ures/business_cpp/kcliques_standalone.cpp b/...ness_cpp/algo_cpp/kcliques_standalone.cpp → ...ures/business_cpp/kcliques_standalone.cpp
diff --git a/...ures/business_cpp/algo_cpp/kcore_core.cpp → procedures/business_cpp/kcore_core.cpp b/...ures/business_cpp/algo_cpp/kcore_core.cpp → procedures/business_cpp/kcore_core.cpp
diff --git a/...business_cpp/algo_cpp/kcore_procedure.cpp → procedures/business_cpp/kcore_procedure.cpp b/...business_cpp/algo_cpp/kcore_procedure.cpp → procedures/business_cpp/kcore_procedure.cpp
diff --git a/...usiness_cpp/algo_cpp/kcore_standalone.cpp → procedures/business_cpp/kcore_standalone.cpp b/...usiness_cpp/algo_cpp/kcore_standalone.cpp → procedures/business_cpp/kcore_standalone.cpp
diff --git a/...edures/business_cpp/algo_cpp/khop_kth.cpp → procedures/business_cpp/khop_kth.cpp b/...edures/business_cpp/algo_cpp/khop_kth.cpp → procedures/business_cpp/khop_kth.cpp
diff --git a/...res/business_cpp/algo_cpp/khop_within.cpp → procedures/business_cpp/khop_within.cpp b/...res/business_cpp/algo_cpp/khop_within.cpp → procedures/business_cpp/khop_within.cpp
diff --git a/...res/business_cpp/algo_cpp/ktruss_core.cpp → procedures/business_cpp/ktruss_core.cpp b/...res/business_cpp/algo_cpp/ktruss_core.cpp → procedures/business_cpp/ktruss_core.cpp
diff --git a/...usiness_cpp/algo_cpp/ktruss_procedure.cpp → procedures/business_cpp/ktruss_procedure.cpp b/...usiness_cpp/algo_cpp/ktruss_procedure.cpp → procedures/business_cpp/ktruss_procedure.cpp
diff --git a/...siness_cpp/algo_cpp/ktruss_standalone.cpp → ...edures/business_cpp/ktruss_standalone.cpp b/...siness_cpp/algo_cpp/ktruss_standalone.cpp → ...edures/business_cpp/ktruss_standalone.cpp
diff --git a/...edures/business_cpp/algo_cpp/lcc_core.cpp → procedures/business_cpp/lcc_core.cpp b/...edures/business_cpp/algo_cpp/lcc_core.cpp → procedures/business_cpp/lcc_core.cpp
diff --git a/...s/business_cpp/algo_cpp/lcc_procedure.cpp → procedures/business_cpp/lcc_procedure.cpp b/...s/business_cpp/algo_cpp/lcc_procedure.cpp → procedures/business_cpp/lcc_procedure.cpp
@@ -90,7 +90,7 @@ extern "C" bool Process(GraphDB& db, const std::string& request, std::string& re
     // output
     start_time = get_time();
     if (output_file != "") {
-        olapondb.WriteToFile<double>(score, output_file);
+        olapondb.WriteToFile<double>(true, score, output_file);
     }
     txn.Commit();
 

diff --git a/...usiness_cpp/algo_cpp/lcc_procedure_v2.cpp → procedures/business_cpp/lcc_procedure_v2.cpp b/...usiness_cpp/algo_cpp/lcc_procedure_v2.cpp → procedures/business_cpp/lcc_procedure_v2.cpp
diff --git a/.../business_cpp/algo_cpp/lcc_standalone.cpp → procedures/business_cpp/lcc_standalone.cpp b/.../business_cpp/algo_cpp/lcc_standalone.cpp → procedures/business_cpp/lcc_standalone.cpp
diff --git a/...res/business_cpp/algo_cpp/leiden_core.cpp → procedures/business_cpp/leiden_core.cpp b/...res/business_cpp/algo_cpp/leiden_core.cpp → procedures/business_cpp/leiden_core.cpp
diff --git a/...usiness_cpp/algo_cpp/leiden_procedure.cpp → procedures/business_cpp/leiden_procedure.cpp b/...usiness_cpp/algo_cpp/leiden_procedure.cpp → procedures/business_cpp/leiden_procedure.cpp
@@ -72,7 +72,7 @@ extern "C" bool Process(GraphDB& db, const std::string& request, std::string& re
     // output
     start_time = get_time();
     if (output_file != "") {
-        olapondb.WriteToFile<size_t>(label, output_file);
+        olapondb.WriteToFile<size_t>(true, label, output_file);
     }
 
     double output_cost = get_time() - start_time;

diff --git a/...siness_cpp/algo_cpp/leiden_standalone.cpp → ...edures/business_cpp/leiden_standalone.cpp b/...siness_cpp/algo_cpp/leiden_standalone.cpp → ...edures/business_cpp/leiden_standalone.cpp
diff --git a/...siness_cpp/algo_cpp/locate_cycle_core.cpp → ...edures/business_cpp/locate_cycle_core.cpp b/...siness_cpp/algo_cpp/locate_cycle_core.cpp → ...edures/business_cpp/locate_cycle_core.cpp
diff --git a/...s_cpp/algo_cpp/locate_cycle_procedure.cpp → ...s/business_cpp/locate_cycle_procedure.cpp b/...s_cpp/algo_cpp/locate_cycle_procedure.cpp → ...s/business_cpp/locate_cycle_procedure.cpp
diff --git a/..._cpp/algo_cpp/locate_cycle_standalone.cpp → .../business_cpp/locate_cycle_standalone.cpp b/..._cpp/algo_cpp/locate_cycle_standalone.cpp → .../business_cpp/locate_cycle_standalone.cpp
diff --git a/...es/business_cpp/algo_cpp/louvain_core.cpp → procedures/business_cpp/louvain_core.cpp b/...es/business_cpp/algo_cpp/louvain_core.cpp → procedures/business_cpp/louvain_core.cpp
diff --git a/...siness_cpp/algo_cpp/louvain_procedure.cpp → ...edures/business_cpp/louvain_procedure.cpp b/...siness_cpp/algo_cpp/louvain_procedure.cpp → ...edures/business_cpp/louvain_procedure.cpp
diff --git a/...iness_cpp/algo_cpp/louvain_standalone.cpp → ...dures/business_cpp/louvain_standalone.cpp b/...iness_cpp/algo_cpp/louvain_standalone.cpp → ...dures/business_cpp/louvain_standalone.cpp
diff --git a/...edures/business_cpp/algo_cpp/lpa_core.cpp → procedures/business_cpp/lpa_core.cpp b/...edures/business_cpp/algo_cpp/lpa_core.cpp → procedures/business_cpp/lpa_core.cpp
diff --git a/...s/business_cpp/algo_cpp/lpa_procedure.cpp → procedures/business_cpp/lpa_procedure.cpp b/...s/business_cpp/algo_cpp/lpa_procedure.cpp → procedures/business_cpp/lpa_procedure.cpp
@@ -93,7 +93,7 @@ extern "C" bool Process(GraphDB& db, const std::string& request, std::string& re
     // output
     start_time = get_time();
     if (output_file != "") {
-        olapondb.WriteToFile<size_t>(label, output_file);
+        olapondb.WriteToFile<size_t>(true, label, output_file);
     }
     txn.Commit();
 

diff --git a/...usiness_cpp/algo_cpp/lpa_procedure_v2.cpp → procedures/business_cpp/lpa_procedure_v2.cpp b/...usiness_cpp/algo_cpp/lpa_procedure_v2.cpp → procedures/business_cpp/lpa_procedure_v2.cpp
diff --git a/.../business_cpp/algo_cpp/lpa_standalone.cpp → procedures/business_cpp/lpa_standalone.cpp b/.../business_cpp/algo_cpp/lpa_standalone.cpp → procedures/business_cpp/lpa_standalone.cpp
diff --git a/...edures/business_cpp/algo_cpp/mis_core.cpp → procedures/business_cpp/mis_core.cpp b/...edures/business_cpp/algo_cpp/mis_core.cpp → procedures/business_cpp/mis_core.cpp
diff --git a/...s/business_cpp/algo_cpp/mis_procedure.cpp → procedures/business_cpp/mis_procedure.cpp b/...s/business_cpp/algo_cpp/mis_procedure.cpp → procedures/business_cpp/mis_procedure.cpp
diff --git a/.../business_cpp/algo_cpp/mis_standalone.cpp → procedures/business_cpp/mis_standalone.cpp b/.../business_cpp/algo_cpp/mis_standalone.cpp → procedures/business_cpp/mis_standalone.cpp
diff --git a/...ures/business_cpp/algo_cpp/motif_core.cpp → procedures/business_cpp/motif_core.cpp b/...ures/business_cpp/algo_cpp/motif_core.cpp → procedures/business_cpp/motif_core.cpp
diff --git a/...business_cpp/algo_cpp/motif_procedure.cpp → procedures/business_cpp/motif_procedure.cpp b/...business_cpp/algo_cpp/motif_procedure.cpp → procedures/business_cpp/motif_procedure.cpp
diff --git a/...usiness_cpp/algo_cpp/motif_standalone.cpp → procedures/business_cpp/motif_standalone.cpp b/...usiness_cpp/algo_cpp/motif_standalone.cpp → procedures/business_cpp/motif_standalone.cpp
diff --git a/...dures/business_cpp/algo_cpp/mssp_core.cpp → procedures/business_cpp/mssp_core.cpp b/...dures/business_cpp/algo_cpp/mssp_core.cpp → procedures/business_cpp/mssp_core.cpp
diff --git a/.../business_cpp/algo_cpp/mssp_procedure.cpp → procedures/business_cpp/mssp_procedure.cpp b/.../business_cpp/algo_cpp/mssp_procedure.cpp → procedures/business_cpp/mssp_procedure.cpp
diff --git a/...business_cpp/algo_cpp/mssp_standalone.cpp → procedures/business_cpp/mssp_standalone.cpp b/...business_cpp/algo_cpp/mssp_standalone.cpp → procedures/business_cpp/mssp_standalone.cpp
diff --git a/...s/business_cpp/algo_cpp/pagerank_core.cpp → procedures/business_cpp/pagerank_core.cpp b/...s/business_cpp/algo_cpp/pagerank_core.cpp → procedures/business_cpp/pagerank_core.cpp
diff --git a/...iness_cpp/algo_cpp/pagerank_procedure.cpp → ...dures/business_cpp/pagerank_procedure.cpp b/...iness_cpp/algo_cpp/pagerank_procedure.cpp → ...dures/business_cpp/pagerank_procedure.cpp
@@ -99,7 +99,7 @@ extern "C" bool Process(GraphDB& db, const std::string& request, std::string& re
     // output
     start_time = get_time();
     if (output_file != "") {
-        olapondb.WriteToFile<double>(pr, output_file);
+        olapondb.WriteToFile<double>(true, pr, output_file);
     }
     txn.Commit();
 

diff --git a/...ss_cpp/algo_cpp/pagerank_procedure_v2.cpp → ...es/business_cpp/pagerank_procedure_v2.cpp b/...ss_cpp/algo_cpp/pagerank_procedure_v2.cpp → ...es/business_cpp/pagerank_procedure_v2.cpp
diff --git a/...ness_cpp/algo_cpp/pagerank_standalone.cpp → ...ures/business_cpp/pagerank_standalone.cpp b/...ness_cpp/algo_cpp/pagerank_standalone.cpp → ...ures/business_cpp/pagerank_standalone.cpp
diff --git a/...edures/business_cpp/algo_cpp/ppr_core.cpp → procedures/business_cpp/ppr_core.cpp b/...edures/business_cpp/algo_cpp/ppr_core.cpp → procedures/business_cpp/ppr_core.cpp
diff --git a/...s/business_cpp/algo_cpp/ppr_procedure.cpp → procedures/business_cpp/ppr_procedure.cpp b/...s/business_cpp/algo_cpp/ppr_procedure.cpp → procedures/business_cpp/ppr_procedure.cpp
diff --git a/.../business_cpp/algo_cpp/ppr_standalone.cpp → procedures/business_cpp/ppr_standalone.cpp b/.../business_cpp/algo_cpp/ppr_standalone.cpp → procedures/business_cpp/ppr_standalone.cpp
diff --git a/...edures/business_cpp/algo_cpp/scc_core.cpp → procedures/business_cpp/scc_core.cpp b/...edures/business_cpp/algo_cpp/scc_core.cpp → procedures/business_cpp/scc_core.cpp
diff --git a/...s/business_cpp/algo_cpp/scc_procedure.cpp → procedures/business_cpp/scc_procedure.cpp b/...s/business_cpp/algo_cpp/scc_procedure.cpp → procedures/business_cpp/scc_procedure.cpp
diff --git a/.../business_cpp/algo_cpp/scc_standalone.cpp → procedures/business_cpp/scc_standalone.cpp b/.../business_cpp/algo_cpp/scc_standalone.cpp → procedures/business_cpp/scc_standalone.cpp
diff --git a/...dures/business_cpp/algo_cpp/slpa_core.cpp → procedures/business_cpp/slpa_core.cpp b/...dures/business_cpp/algo_cpp/slpa_core.cpp → procedures/business_cpp/slpa_core.cpp
diff --git a/.../business_cpp/algo_cpp/slpa_procedure.cpp → procedures/business_cpp/slpa_procedure.cpp b/.../business_cpp/algo_cpp/slpa_procedure.cpp → procedures/business_cpp/slpa_procedure.cpp
diff --git a/...business_cpp/algo_cpp/slpa_standalone.cpp → procedures/business_cpp/slpa_standalone.cpp b/...business_cpp/algo_cpp/slpa_standalone.cpp → procedures/business_cpp/slpa_standalone.cpp
diff --git a/...dures/business_cpp/algo_cpp/spsp_core.cpp → procedures/business_cpp/spsp_core.cpp b/...dures/business_cpp/algo_cpp/spsp_core.cpp → procedures/business_cpp/spsp_core.cpp
diff --git a/.../business_cpp/algo_cpp/spsp_procedure.cpp → procedures/business_cpp/spsp_procedure.cpp b/.../business_cpp/algo_cpp/spsp_procedure.cpp → procedures/business_cpp/spsp_procedure.cpp
diff --git a/...business_cpp/algo_cpp/spsp_standalone.cpp → procedures/business_cpp/spsp_standalone.cpp b/...business_cpp/algo_cpp/spsp_standalone.cpp → procedures/business_cpp/spsp_standalone.cpp
diff --git a/...dures/business_cpp/algo_cpp/sssp_core.cpp → procedures/business_cpp/sssp_core.cpp b/...dures/business_cpp/algo_cpp/sssp_core.cpp → procedures/business_cpp/sssp_core.cpp
diff --git a/.../business_cpp/algo_cpp/sssp_procedure.cpp → procedures/business_cpp/sssp_procedure.cpp b/.../business_cpp/algo_cpp/sssp_procedure.cpp → procedures/business_cpp/sssp_procedure.cpp
@@ -79,7 +79,8 @@ extern "C" bool Process(GraphDB& db, const std::string& request, std::string& re
     // output
     start_time = get_time();
     if (output_file != "") {
-        olapondb.WriteToFile<double>(distance, output_file, [&](size_t vid, double& vdata) -> bool {
+        olapondb.WriteToFile<double>(true, distance, output_file,
+                                    [&](size_t vid, double& vdata) -> bool {
             return vdata != SSSP_INIT_VALUE;
         });
     }

diff --git a/...siness_cpp/algo_cpp/sssp_procedure_v2.cpp → ...edures/business_cpp/sssp_procedure_v2.cpp b/...siness_cpp/algo_cpp/sssp_procedure_v2.cpp → ...edures/business_cpp/sssp_procedure_v2.cpp
diff --git a/...business_cpp/algo_cpp/sssp_standalone.cpp → procedures/business_cpp/sssp_standalone.cpp b/...business_cpp/algo_cpp/sssp_standalone.cpp → procedures/business_cpp/sssp_standalone.cpp
diff --git a/...pp/algo_cpp/subgraph_isomorphism_core.cpp → ...usiness_cpp/subgraph_isomorphism_core.cpp b/...pp/algo_cpp/subgraph_isomorphism_core.cpp → ...usiness_cpp/subgraph_isomorphism_core.cpp
diff --git a/...go_cpp/subgraph_isomorphism_procedure.cpp → ...ss_cpp/subgraph_isomorphism_procedure.cpp b/...go_cpp/subgraph_isomorphism_procedure.cpp → ...ss_cpp/subgraph_isomorphism_procedure.cpp
diff --git a/...o_cpp/subgraph_isomorphism_standalone.cpp → ...s_cpp/subgraph_isomorphism_standalone.cpp b/...o_cpp/subgraph_isomorphism_standalone.cpp → ...s_cpp/subgraph_isomorphism_standalone.cpp
diff --git a/.../business_cpp/algo_cpp/sybilrank_core.cpp → procedures/business_cpp/sybilrank_core.cpp b/.../business_cpp/algo_cpp/sybilrank_core.cpp → procedures/business_cpp/sybilrank_core.cpp
diff --git a/...ness_cpp/algo_cpp/sybilrank_procedure.cpp → ...ures/business_cpp/sybilrank_procedure.cpp b/...ness_cpp/algo_cpp/sybilrank_procedure.cpp → ...ures/business_cpp/sybilrank_procedure.cpp
diff --git a/...ess_cpp/algo_cpp/sybilrank_standalone.cpp → ...res/business_cpp/sybilrank_standalone.cpp b/...ess_cpp/algo_cpp/sybilrank_standalone.cpp → ...res/business_cpp/sybilrank_standalone.cpp
diff --git a/...s/business_cpp/algo_cpp/triangle_core.cpp → procedures/business_cpp/triangle_core.cpp b/...s/business_cpp/algo_cpp/triangle_core.cpp → procedures/business_cpp/triangle_core.cpp
diff --git a/...iness_cpp/algo_cpp/triangle_procedure.cpp → ...dures/business_cpp/triangle_procedure.cpp b/...iness_cpp/algo_cpp/triangle_procedure.cpp → ...dures/business_cpp/triangle_procedure.cpp
diff --git a/...ness_cpp/algo_cpp/triangle_standalone.cpp → ...ures/business_cpp/triangle_standalone.cpp b/...ness_cpp/algo_cpp/triangle_standalone.cpp → ...ures/business_cpp/triangle_standalone.cpp
diff --git a/.../business_cpp/algo_cpp/trustrank_core.cpp → procedures/business_cpp/trustrank_core.cpp b/.../business_cpp/algo_cpp/trustrank_core.cpp → procedures/business_cpp/trustrank_core.cpp
diff --git a/...ness_cpp/algo_cpp/trustrank_procedure.cpp → ...ures/business_cpp/trustrank_procedure.cpp b/...ness_cpp/algo_cpp/trustrank_procedure.cpp → ...ures/business_cpp/trustrank_procedure.cpp
@@ -75,7 +75,7 @@ extern "C" bool Process(GraphDB& db, const std::string& request, std::string& re
     // output
     start_time = get_time();
     if (output_file != "") {
-        olapondb.WriteToFile<double>(curr, output_file);
+        olapondb.WriteToFile<double>(true, curr, output_file);
     }
     // TODO(any): write curr back to graph
     auto output_cost = get_time() - start_time;

diff --git a/...ess_cpp/algo_cpp/trustrank_standalone.cpp → ...res/business_cpp/trustrank_standalone.cpp b/...ess_cpp/algo_cpp/trustrank_standalone.cpp → ...res/business_cpp/trustrank_standalone.cpp
diff --git a/...edures/business_cpp/algo_cpp/wcc_core.cpp → procedures/business_cpp/wcc_core.cpp b/...edures/business_cpp/algo_cpp/wcc_core.cpp → procedures/business_cpp/wcc_core.cpp
diff --git a/...s/business_cpp/algo_cpp/wcc_procedure.cpp → procedures/business_cpp/wcc_procedure.cpp b/...s/business_cpp/algo_cpp/wcc_procedure.cpp → procedures/business_cpp/wcc_procedure.cpp
@@ -92,7 +92,7 @@ extern "C" bool Process(GraphDB& db, const std::string& request, std::string& re
     // output
     start_time = get_time();
     if (output_file != "") {
-        olapondb.WriteToFile<size_t>(label, output_file);
+        olapondb.WriteToFile<size_t>(true, label, output_file);
     }
 
     size_t num_components, max_component;

diff --git a/...usiness_cpp/algo_cpp/wcc_procedure_v2.cpp → procedures/business_cpp/wcc_procedure_v2.cpp b/...usiness_cpp/algo_cpp/wcc_procedure_v2.cpp → procedures/business_cpp/wcc_procedure_v2.cpp
diff --git a/.../business_cpp/algo_cpp/wcc_standalone.cpp → procedures/business_cpp/wcc_standalone.cpp b/.../business_cpp/algo_cpp/wcc_standalone.cpp → procedures/business_cpp/wcc_standalone.cpp
diff --git a/...dures/business_cpp/algo_cpp/wlpa_core.cpp → procedures/business_cpp/wlpa_core.cpp b/...dures/business_cpp/algo_cpp/wlpa_core.cpp → procedures/business_cpp/wlpa_core.cpp
diff --git a/.../business_cpp/algo_cpp/wlpa_procedure.cpp → procedures/business_cpp/wlpa_procedure.cpp b/.../business_cpp/algo_cpp/wlpa_procedure.cpp → procedures/business_cpp/wlpa_procedure.cpp
diff --git a/...business_cpp/algo_cpp/wlpa_standalone.cpp → procedures/business_cpp/wlpa_standalone.cpp b/...business_cpp/algo_cpp/wlpa_standalone.cpp → procedures/business_cpp/wlpa_standalone.cpp
diff --git a/.../business_cpp/algo_cpp/wpagerank_core.cpp → procedures/business_cpp/wpagerank_core.cpp b/.../business_cpp/algo_cpp/wpagerank_core.cpp → procedures/business_cpp/wpagerank_core.cpp
diff --git a/...ness_cpp/algo_cpp/wpagerank_procedure.cpp → ...ures/business_cpp/wpagerank_procedure.cpp b/...ness_cpp/algo_cpp/wpagerank_procedure.cpp → ...ures/business_cpp/wpagerank_procedure.cpp
diff --git a/...ess_cpp/algo_cpp/wpagerank_standalone.cpp → ...res/business_cpp/wpagerank_standalone.cpp b/...ess_cpp/algo_cpp/wpagerank_standalone.cpp → ...res/business_cpp/wpagerank_standalone.cpp