[ALGOS-263] feat(algos): convert some of the algorithms from singlde …

…mode to distributed mode;
tigergraph · Jul 10, 2024 · 2ba501b · 2ba501b
1 parent aabbd3c
commit 2ba501b
Show file tree

Hide file tree

Showing 31 changed files with 32 additions and 32 deletions.
diff --git a/algorithms/Centrality/article_rank/tg_article_rank.gsql b/algorithms/Centrality/article_rank/tg_article_rank.gsql
@@ -1,4 +1,4 @@
-CREATE QUERY tg_article_rank (STRING v_type, STRING e_type,
+CREATE DISTRIBUTED QUERY tg_article_rank (STRING v_type, STRING e_type,
     FLOAT max_change = 0.001, INT maximum_iteration = 25, FLOAT damping = 0.85, INT top_k = 100,
     BOOL print_results = TRUE, STRING result_attribute =    "", STRING file_path = "") SYNTAX V1 {
 

diff --git a/algorithms/Centrality/closeness/approximate/tg_closeness_cent_approx.gsql b/algorithms/Centrality/closeness/approximate/tg_closeness_cent_approx.gsql
@@ -1,4 +1,4 @@
-CREATE QUERY tg_closeness_cent_approx (
+CREATE DISTRIBUTED QUERY tg_closeness_cent_approx (
     SET<STRING> v_type_set, SET<STRING> e_type_set, STRING reverse_e_type, INT top_k=100, INT k = 100,  INT max_hops = 10,  DOUBLE epsilon = 0.1,  BOOL print_results = true, 
     STRING file_path = "",  INT debug = 0,  INT sample_index = 0,  INT max_size = 1000,   BOOL wf = True ) SYNTAX V1 {
 

diff --git a/algorithms/Centrality/degree/unweighted/tg_degree_cent.gsql b/algorithms/Centrality/degree/unweighted/tg_degree_cent.gsql
@@ -1,4 +1,4 @@
-CREATE QUERY tg_degree_cent(SET<STRING> v_type_set, SET<STRING> e_type_set, SET<STRING> reverse_e_type_set, BOOL in_degree = TRUE, BOOL out_degree = TRUE,
+CREATE DISTRIBUTED QUERY tg_degree_cent(SET<STRING> v_type_set, SET<STRING> e_type_set, SET<STRING> reverse_e_type_set, BOOL in_degree = TRUE, BOOL out_degree = TRUE,
   INT top_k=100, BOOL print_results = TRUE, STRING result_attribute = "",STRING file_path = "") SYNTAX V1 {
 
     /*

diff --git a/algorithms/Centrality/degree/weighted/tg_weighted_degree_cent.gsql b/algorithms/Centrality/degree/weighted/tg_weighted_degree_cent.gsql
@@ -1,4 +1,4 @@
-CREATE QUERY tg_weighted_degree_cent(STRING v_type, STRING e_type, STRING reverse_e_type, string weight_attribute, BOOL in_degree = TRUE, BOOL out_degree = TRUE, INT top_k=100, BOOL print_results = TRUE, STRING result_attribute = "",STRING file_path = "") SYNTAX V1 {
+CREATE DISTRIBUTED QUERY tg_weighted_degree_cent(STRING v_type, STRING e_type, STRING reverse_e_type, string weight_attribute, BOOL in_degree = TRUE, BOOL out_degree = TRUE, INT top_k=100, BOOL print_results = TRUE, STRING result_attribute = "",STRING file_path = "") SYNTAX V1 {
 
    /*
    First Author: <First Author Name>

diff --git a/algorithms/Centrality/eigenvector/tg_eigenvector_cent.gsql b/algorithms/Centrality/eigenvector/tg_eigenvector_cent.gsql
@@ -1,4 +1,4 @@
-CREATE QUERY tg_eigenvector_cent(SET<STRING> v_type_set, SET<STRING> e_type_set, INT maximum_iteration = 100, FLOAT conv_limit = 0.000001,
+CREATE DISTRIBUTED QUERY tg_eigenvector_cent(SET<STRING> v_type_set, SET<STRING> e_type_set, INT maximum_iteration = 100, FLOAT conv_limit = 0.000001,
     INT top_k = 100, BOOL print_results = True, STRING result_attribute = "",STRING file_path = ""
     ) SYNTAX V1 {
 

diff --git a/algorithms/Centrality/harmonic/tg_harmonic_cent.gsql b/algorithms/Centrality/harmonic/tg_harmonic_cent.gsql
@@ -1,4 +1,4 @@
-CREATE QUERY tg_harmonic_cent(SET<STRING> v_type_set, SET<STRING> e_type_set, SET<STRING> reverse_e_type_set,INT max_hops = 10,
+CREATE DISTRIBUTED QUERY tg_harmonic_cent(SET<STRING> v_type_set, SET<STRING> e_type_set, SET<STRING> reverse_e_type_set,INT max_hops = 10,
   INT top_k = 100, BOOL wf = TRUE, BOOL print_results = True, STRING result_attribute = "",
   STRING file_path = "", BOOL display_edges = FALSE) SYNTAX V1 { 
 

diff --git a/algorithms/Centrality/influence_maximization/CELF/tg_influence_maximization_CELF.gsql b/algorithms/Centrality/influence_maximization/CELF/tg_influence_maximization_CELF.gsql
@@ -1,4 +1,4 @@
-CREATE QUERY tg_influence_maximization_CELF(STRING v_type,STRING e_type,STRING weight_attribute,INT top_k,
+CREATE DISTRIBUTED QUERY tg_influence_maximization_CELF(STRING v_type,STRING e_type,STRING weight_attribute,INT top_k,
   BOOL print_results = True, STRING file_path = "")  SYNTAX V1 {
 
     /*
@@ -128,4 +128,4 @@ CREATE QUERY tg_influence_maximization_CELF(STRING v_type,STRING e_type,STRING w
   IF print_results THEN
      PRINT @@res_list;
   END;
-}
+}
diff --git a/algorithms/Centrality/influence_maximization/greedy/tg_influence_maximization_greedy.gsql b/algorithms/Centrality/influence_maximization/greedy/tg_influence_maximization_greedy.gsql
@@ -1,4 +1,4 @@
-CREATE QUERY tg_influence_maximization_greedy(STRING v_type,STRING e_type,STRING weight_attribute,INT top_k,
+CREATE DISTRIBUTED QUERY tg_influence_maximization_greedy(STRING v_type,STRING e_type,STRING weight_attribute,INT top_k,
   BOOL print_results = True, STRING file_path = "") SYNTAX V1 {
 
     /*

diff --git a/algorithms/Centrality/pagerank/global/unweighted/tg_pagerank.gsql b/algorithms/Centrality/pagerank/global/unweighted/tg_pagerank.gsql
@@ -1,4 +1,4 @@
-CREATE QUERY tg_pagerank (STRING v_type, STRING e_type,
+CREATE DISTRIBUTED QUERY tg_pagerank (STRING v_type, STRING e_type,
  FLOAT max_change=0.001, INT maximum_iteration=25, FLOAT damping=0.85, INT top_k = 100,
  BOOL print_results = TRUE, STRING result_attribute =  "", STRING file_path = "",
  BOOL display_edges = FALSE) SYNTAX V1 {

diff --git a/algorithms/Centrality/pagerank/global/weighted/tg_pagerank_wt.gsql b/algorithms/Centrality/pagerank/global/weighted/tg_pagerank_wt.gsql
@@ -1,4 +1,4 @@
-CREATE QUERY tg_pagerank_wt (STRING v_type, STRING e_type, STRING weight_attribute,
+CREATE DISTRIBUTED QUERY tg_pagerank_wt (STRING v_type, STRING e_type, STRING weight_attribute,
  FLOAT max_change=0.001, INT maximum_iteration=25, FLOAT damping=0.85, INT top_k = 100,
  BOOL print_results = TRUE, STRING result_attribute =  "", STRING file_path = "",
  BOOL display_edges = FALSE) SYNTAX V1 {

diff --git a/algorithms/Centrality/pagerank/personalized/all_pairs/tg_pagerank_pers_ap_batch.gsql b/algorithms/Centrality/pagerank/personalized/all_pairs/tg_pagerank_pers_ap_batch.gsql
@@ -1,4 +1,4 @@
-CREATE QUERY tg_pagerank_pers_ap_batch(STRING v_type, STRING e_type,
+CREATE DISTRIBUTED QUERY tg_pagerank_pers_ap_batch(STRING v_type, STRING e_type,
   FLOAT max_change=0.001, INT maximum_iteration=25, FLOAT damping = 0.85, INT top_k = 100,INT batch_num,BOOL print_results,STRING file_path) SYNTAX V1 {
 
     /*

diff --git a/algorithms/Centrality/pagerank/personalized/multi_source/tg_pagerank_pers.gsql b/algorithms/Centrality/pagerank/personalized/multi_source/tg_pagerank_pers.gsql
@@ -1,4 +1,4 @@
-CREATE QUERY tg_pagerank_pers(SET<VERTEX> source, STRING e_type,
+CREATE DISTRIBUTED QUERY tg_pagerank_pers(SET<VERTEX> source, STRING e_type,
   FLOAT max_change=0.001, INT maximum_iteration=25, FLOAT damping = 0.85, INT top_k = 100,
   BOOL print_results = TRUE, STRING result_attribute = "", STRING file_path = "") SYNTAX V1 {
 

diff --git a/algorithms/Classification/greedy_graph_coloring/tg_greedy_graph_coloring.gsql b/algorithms/Classification/greedy_graph_coloring/tg_greedy_graph_coloring.gsql
@@ -1,4 +1,4 @@
-CREATE QUERY tg_greedy_graph_coloring(SET<STRING> v_type_set,SET<STRING> e_type_set,UINT max_colors = 999999,
+CREATE DISTRIBUTED QUERY tg_greedy_graph_coloring(SET<STRING> v_type_set,SET<STRING> e_type_set,UINT max_colors = 999999,
   BOOL print_color_count = TRUE, BOOL print_stats = TRUE, STRING file_path = "")  SYNTAX V1 {
 
     /*

diff --git a/algorithms/Classification/k_nearest_neighbors/single_source/tg_knn_cosine_ss.gsql b/algorithms/Classification/k_nearest_neighbors/single_source/tg_knn_cosine_ss.gsql
@@ -1,4 +1,4 @@
-CREATE QUERY tg_knn_cosine_ss (VERTEX source, SET<STRING> v_type_set, SET<STRING> e_type_set, SET<STRING> reverse_e_type_set, STRING weight_attribute, 
+CREATE DISTRIBUTED QUERY tg_knn_cosine_ss (VERTEX source, SET<STRING> v_type_set, SET<STRING> e_type_set, SET<STRING> reverse_e_type_set, STRING weight_attribute, 
   STRING label, INT top_k, BOOL print_results = TRUE, STRING file_path = "", STRING result_attribute = "") RETURNS (STRING)  SYNTAX V1 {
 
     /*

diff --git a/algorithms/Classification/maximal_independent_set/deterministic/tg_maximal_indep_set.gsql b/algorithms/Classification/maximal_independent_set/deterministic/tg_maximal_indep_set.gsql
@@ -1,4 +1,4 @@
-CREATE QUERY tg_maximal_indep_set(STRING v_type, STRING e_type, INT maximum_iteration = 100, BOOL print_results = TRUE, STRING file_path = "")  SYNTAX V1 { 
+CREATE DISTRIBUTED QUERY tg_maximal_indep_set(STRING v_type, STRING e_type, INT maximum_iteration = 100, BOOL print_results = TRUE, STRING file_path = "")  SYNTAX V1 { 
 
     /*
     First Author: <First Author Name>

diff --git a/algorithms/Community/connected_components/strongly_connected_components/standard/tg_scc.gsql b/algorithms/Community/connected_components/strongly_connected_components/standard/tg_scc.gsql
@@ -1,4 +1,4 @@
-CREATE QUERY tg_scc (SET<STRING> v_type_set, SET<STRING> e_type_set, SET<STRING> reverse_e_type_set,
+CREATE DISTRIBUTED QUERY tg_scc (SET<STRING> v_type_set, SET<STRING> e_type_set, SET<STRING> reverse_e_type_set,
   INT top_k_dist, INT print_limit, INT maximum_iteration = 500, INT iter_wcc = 5, BOOL print_results = TRUE, STRING result_attribute= "", STRING file_path="")  SYNTAX V1 { 
     //INT iter_end_trim = 3
 

diff --git a/algorithms/Community/connected_components/weakly_connected_components/standard/tg_wcc.gsql b/algorithms/Community/connected_components/weakly_connected_components/standard/tg_wcc.gsql
@@ -1,4 +1,4 @@
-CREATE QUERY tg_wcc (SET<STRING> v_type_set, SET<STRING> e_type_set, INT print_limit = 100,
+CREATE DISTRIBUTED QUERY tg_wcc (SET<STRING> v_type_set, SET<STRING> e_type_set, INT print_limit = 100,
  BOOL print_results = TRUE, STRING result_attribute = "", STRING file_path = "")  SYNTAX V1 {
 
     /*

diff --git a/algorithms/Community/k_core/tg_kcore.gsql b/algorithms/Community/k_core/tg_kcore.gsql
@@ -1,4 +1,4 @@
-CREATE QUERY tg_kcore(STRING v_type, STRING e_type, INT k_min = 0, INT k_max = -1, BOOL print_results = TRUE, 
+CREATE DISTRIBUTED QUERY tg_kcore(STRING v_type, STRING e_type, INT k_min = 0, INT k_max = -1, BOOL print_results = TRUE, 
   STRING result_attribute = "", STRING file_path = "", BOOL print_all_k = FALSE, BOOL show_shells=FALSE)  SYNTAX V1 { 
 
     /*

diff --git a/algorithms/Community/label_propagation/tg_label_prop.gsql b/algorithms/Community/label_propagation/tg_label_prop.gsql
@@ -1,4 +1,4 @@
-CREATE QUERY tg_label_prop (SET<STRING> v_type_set, SET<STRING> e_type_set, INT maximum_iteration, INT print_limit, 
+CREATE DISTRIBUTED QUERY tg_label_prop (SET<STRING> v_type_set, SET<STRING> e_type_set, INT maximum_iteration, INT print_limit, 
   BOOL print_results = TRUE, STRING file_path = "", STRING result_attribute = "")  SYNTAX V1 {
 
 

diff --git a/algorithms/Community/local_clustering_coefficient/tg_lcc.gsql b/algorithms/Community/local_clustering_coefficient/tg_lcc.gsql
@@ -1,4 +1,4 @@
-CREATE QUERY tg_lcc (STRING v_type, STRING e_type,INT top_k=100,BOOL print_results = True, STRING result_attribute = "",
+CREATE DISTRIBUTED QUERY tg_lcc (STRING v_type, STRING e_type,INT top_k=100,BOOL print_results = True, STRING result_attribute = "",
   STRING file_path = "", BOOL display_edges = FALSE)  SYNTAX V1 { 
 
     /*

diff --git a/algorithms/Community/louvain/tg_louvain.gsql b/algorithms/Community/louvain/tg_louvain.gsql
@@ -1,4 +1,4 @@
-CREATE QUERY tg_louvain(SET<STRING> v_type_set, SET<STRING> e_type_set, STRING weight_attribute = "weight", INT maximum_iteration = 10, 
+CREATE DISTRIBUTED QUERY tg_louvain(SET<STRING> v_type_set, SET<STRING> e_type_set, STRING weight_attribute = "weight", INT maximum_iteration = 10, 
   STRING result_attribute = "cid", STRING file_path = "", BOOL print_stats = FALSE)  SYNTAX V1 {
 
     /*

diff --git a/algorithms/Community/speaker-listener_label_propagation/tg_slpa.gsql b/algorithms/Community/speaker-listener_label_propagation/tg_slpa.gsql
@@ -1,4 +1,4 @@
-CREATE QUERY tg_slpa (SET<STRING> v_type_set, SET<STRING> e_type_set, FLOAT threshold, INT maximum_iteration, INT print_limit,
+CREATE DISTRIBUTED QUERY tg_slpa (SET<STRING> v_type_set, SET<STRING> e_type_set, FLOAT threshold, INT maximum_iteration, INT print_limit,
 BOOL print_results = TRUE, STRING file_path = "") SYNTAX V1 {
 
     /*

diff --git a/algorithms/Path/bfs/tg_bfs.gsql b/algorithms/Path/bfs/tg_bfs.gsql
@@ -1,4 +1,4 @@
-CREATE QUERY tg_bfs(SET<STRING> v_type_set, SET<STRING> e_type_set,INT max_hops=10, VERTEX v_start,
+CREATE DISTRIBUTED QUERY tg_bfs(SET<STRING> v_type_set, SET<STRING> e_type_set,INT max_hops=10, VERTEX v_start,
 BOOL print_results = True, STRING result_attribute = "",STRING file_path = "", BOOL display_edges = TRUE) SYNTAX V1 { 
 
     /*

diff --git a/algorithms/Path/cycle_component/tg_cycle_component.gsql b/algorithms/Path/cycle_component/tg_cycle_component.gsql
@@ -1,4 +1,4 @@
-CREATE QUERY tg_cycle_component(STRING v_type,STRING e_type,BOOL print_results = TRUE, STRING result_attribute =  "", STRING file_path = "") SYNTAX v1{ 
+CREATE DISTRIBUTED QUERY tg_cycle_component(STRING v_type,STRING e_type,BOOL print_results = TRUE, STRING result_attribute =  "", STRING file_path = "") SYNTAX v1{ 
 
 
     /*

diff --git a/algorithms/Path/minimum_spanning_forest/tg_msf.gsql b/algorithms/Path/minimum_spanning_forest/tg_msf.gsql
@@ -1,4 +1,4 @@
-CREATE QUERY tg_msf (SET<STRING> v_type_set, SET<STRING> e_type_set, STRING weight_attribute, STRING weight_type,
+CREATE DISTRIBUTED QUERY tg_msf (SET<STRING> v_type_set, SET<STRING> e_type_set, STRING weight_attribute, STRING weight_type,
 	BOOL print_results = TRUE, STRING result_attribute = "", STRING file_path = "")  SYNTAX V1 {
 
     /*

diff --git a/algorithms/Path/minimum_spanning_tree/tg_mst.gsql b/algorithms/Path/minimum_spanning_tree/tg_mst.gsql
@@ -1,4 +1,4 @@
-CREATE QUERY tg_mst(VERTEX opt_source, SET<STRING> v_type_set, SET<STRING> e_type_set, STRING weight_attribute, STRING weight_type,
+CREATE DISTRIBUTED QUERY tg_mst(VERTEX opt_source, SET<STRING> v_type_set, SET<STRING> e_type_set, STRING weight_attribute, STRING weight_type,
   INT maximum_iteration = -1, BOOL print_results = TRUE, STRING result_attribute = "", STRING file_path = "")  SYNTAX V1 {
 
     /*

diff --git a/algorithms/Path/path_between_two_vertices/one_direction/tg_all_path.gsql b/algorithms/Path/path_between_two_vertices/one_direction/tg_all_path.gsql
@@ -1,4 +1,4 @@
-CREATE QUERY tg_all_path(VERTEX v_source, VERTEX target_v, INT depth = 10,
+CREATE DISTRIBUTED QUERY tg_all_path(VERTEX v_source, VERTEX target_v, INT depth = 10,
   BOOL print_results = TRUE, STRING file_path = "")SYNTAX v1 {
 
     /*

diff --git a/algorithms/Path/shortest_path/unweighted/tg_shortest_ss_no_wt.gsql b/algorithms/Path/shortest_path/unweighted/tg_shortest_ss_no_wt.gsql
@@ -1,4 +1,4 @@
-CREATE QUERY tg_shortest_ss_no_wt (VERTEX source, SET<STRING> v_type_set, SET<STRING> e_type_set, 
+CREATE DISTRIBUTED QUERY tg_shortest_ss_no_wt (VERTEX source, SET<STRING> v_type_set, SET<STRING> e_type_set, 
   INT print_limit = -1, BOOL print_results =TRUE, STRING result_attribute ="", STRING file_path ="",
   BOOL display_edges =FALSE)  SYNTAX V1 {
 

diff --git a/algorithms/Path/shortest_path/weighted/any_sign/tg_shortest_ss_any_wt.gsql b/algorithms/Path/shortest_path/weighted/any_sign/tg_shortest_ss_any_wt.gsql
@@ -1,4 +1,4 @@
-CREATE QUERY tg_shortest_ss_any_wt (VERTEX source, SET<STRING> v_type_set, SET<STRING> e_type_set,
+CREATE DISTRIBUTED QUERY tg_shortest_ss_any_wt (VERTEX source, SET<STRING> v_type_set, SET<STRING> e_type_set,
  STRING weight_attribute, STRING weight_type, INT print_limit = -1, BOOL print_results = TRUE,
  STRING result_attribute = "", STRING file_path = "", BOOL display_edges = FALSE)  SYNTAX V1 {
 

diff --git a/algorithms/Path/shortest_path/weighted/positive/summary/tg_shortest_ss_pos_wt.gsql b/algorithms/Path/shortest_path/weighted/positive/summary/tg_shortest_ss_pos_wt.gsql
@@ -1,4 +1,4 @@
-CREATE QUERY tg_shortest_ss_pos_wt (VERTEX source, SET<STRING> v_type_set, SET<STRING> e_type_set,
+CREATE DISTRIBUTED QUERY tg_shortest_ss_pos_wt (VERTEX source, SET<STRING> v_type_set, SET<STRING> e_type_set,
  STRING weight_attribute, STRING weight_type, FLOAT epsilon = 0.001,BOOL print_results = TRUE, INT print_limit = -1, 
  BOOL display_edges = FALSE, STRING result_attribute = "", 
  STRING file_path = "")  SYNTAX V1 {

diff --git a/algorithms/Path/shortest_path/weighted/positive/traceback/tg_shortest_ss_pos_wt_tb.gsql b/algorithms/Path/shortest_path/weighted/positive/traceback/tg_shortest_ss_pos_wt_tb.gsql
@@ -1,4 +1,4 @@
-CREATE QUERY tg_shortest_ss_pos_wt_tb (VERTEX source, SET<STRING> v_type_set, SET<STRING> e_type_set,
+CREATE DISTRIBUTED QUERY tg_shortest_ss_pos_wt_tb (VERTEX source, SET<STRING> v_type_set, SET<STRING> e_type_set,
  STRING weight_attribute, STRING weight_type, FLOAT epsilon = 0.001,BOOL print_results = TRUE, INT print_limit = -1, 
  BOOL display_edges = FALSE, STRING result_attribute = "",
  STRING file_path = "", UINT write_size = 10000)  SYNTAX V1 {