JohT · JohT · Oct 9, 2023 · Oct 4, 2023 · Oct 4, 2023 · Oct 5, 2023
diff --git a/cypher/Community_Detection/Community_Detection_1a_Louvain_Estimate.cypher b/cypher/Community_Detection/Community_Detection_1a_Louvain_Estimate.cypher
@@ -4,7 +4,7 @@ CALL gds.louvain.write.estimate(
  $dependencies_projection + '-without-empty', {
   tolerance: 0.00001,
   relationshipWeightProperty: $dependencies_projection_weight_property,
-  writeProperty: 'louvainCommunityId',
+  writeProperty: $dependencies_projection_write_property,
   includeIntermediateCommunities: true
 })
 YIELD nodeCount

diff --git a/cypher/Community_Detection/Community_Detection_1c_Louvain_Mutate.cypher b/cypher/Community_Detection/Community_Detection_1c_Louvain_Mutate.cypher
@@ -0,0 +1,38 @@
+// Community Detection Louvain Mutate
+
+CALL gds.louvain.mutate(
+ $dependencies_projection + '-without-empty', {
+    tolerance: 0.00001,
+    consecutiveIds: NOT toBoolean($dependencies_include_intermediate_communities),
+    includeIntermediateCommunities: toBoolean($dependencies_include_intermediate_communities),
+    relationshipWeightProperty: $dependencies_projection_weight_property,
+    mutateProperty: $dependencies_projection_write_property
+})
+ YIELD communityCount
+      ,nodePropertiesWritten
+      ,ranLevels
+      ,modularity
+      ,modularities
+      ,preProcessingMillis
+      ,computeMillis
+      ,mutateMillis
+      ,postProcessingMillis
+      ,communityDistribution
+RETURN communityCount
+      ,nodePropertiesWritten
+      ,ranLevels
+      ,modularity
+      ,modularities
+      ,preProcessingMillis
+      ,computeMillis
+      ,mutateMillis
+      ,postProcessingMillis
+      ,communityDistribution.min
+      ,communityDistribution.mean
+      ,communityDistribution.max
+      ,communityDistribution.p50
+      ,communityDistribution.p75
+      ,communityDistribution.p90
+      ,communityDistribution.p95
+      ,communityDistribution.p99
+      ,communityDistribution.p999
diff --git a/...munity_Detection_1c_Louvain_Stream.cypher → ...munity_Detection_1d_Louvain_Stream.cypher b/...munity_Detection_1c_Louvain_Stream.cypher → ...munity_Detection_1d_Louvain_Stream.cypher
diff --git a/cypher/Community_Detection/Community_Detection_1d_Stream_Intermediate_Mutated.cypher b/cypher/Community_Detection/Community_Detection_1d_Stream_Intermediate_Mutated.cypher
@@ -0,0 +1,21 @@
+// Community Detection Stream Intermediate Mutated for hierarchical algorithmns (Louvain, Leiden)
+
+CALL gds.graph.nodeProperty.stream(
+     $dependencies_projection + '-without-empty'
+    ,$dependencies_projection_write_property
+)
+ YIELD nodeId, propertyValue
+  WITH gds.util.asNode(nodeId) AS member
+      ,propertyValue           AS intermediateCommunityIds
+  WITH member
+      ,intermediateCommunityIds
+      ,coalesce(member.fqn, member.fileName, member.name) AS memberName
+  WITH intermediateCommunityIds
+      ,count(DISTINCT member)         AS memberCount
+      ,collect(DISTINCT memberName)   AS memberNames
+RETURN intermediateCommunityIds[0]    AS firstCommunityId
+      ,last(intermediateCommunityIds) AS communityId
+      ,intermediateCommunityIds
+      ,memberCount
+      ,memberNames
+ ORDER BY memberCount DESC, communityId ASC
diff --git a/cypher/Community_Detection/Community_Detection_1e_Louvain_Label_Delete.cypher b/cypher/Community_Detection/Community_Detection_1e_Louvain_Label_Delete.cypher
diff --git a/...ite_intermediateLouvainCommunityId.cypher → ...ite_intermediateLouvainCommunityId.cypher b/...ite_intermediateLouvainCommunityId.cypher → ...ite_intermediateLouvainCommunityId.cypher
@@ -1,11 +1,11 @@
-//Community Detection Louvain Write intermediateLouvainCommunityId
+//Community Detection Louvain Write communityLouvainIntermediateIds
 
 CALL gds.louvain.write(
  $dependencies_projection + '-without-empty', {
     tolerance: 0.00001,
     includeIntermediateCommunities: true,
     relationshipWeightProperty: $dependencies_projection_weight_property,
-    writeProperty: 'intermediateLouvainCommunityId'
+    writeProperty: 'communityLouvainIntermediateIds'
 })
 YIELD preProcessingMillis
      ,computeMillis

diff --git a/...d_Louvain_Write_louvainCommunityId.cypher → ...e_Louvain_Write_louvainCommunityId.cypher b/...d_Louvain_Write_louvainCommunityId.cypher → ...e_Louvain_Write_louvainCommunityId.cypher
@@ -1,11 +1,11 @@
-//Community Detection Louvain write node property louvainCommunityId
+//Community Detection Louvain write node property communityLouvainId
 
 CALL gds.louvain.write(
  $dependencies_projection + '-without-empty', {
     tolerance: 0.00001,
     consecutiveIds: true,
     relationshipWeightProperty: $dependencies_projection_weight_property,
-    writeProperty: 'louvainCommunityId'
+    writeProperty: 'communityLouvainId'
 })
 YIELD preProcessingMillis
      ,computeMillis

diff --git a/cypher/Community_Detection/Community_Detection_1f_Louvain_Label.cypher b/cypher/Community_Detection/Community_Detection_1f_Louvain_Label.cypher
diff --git a/cypher/Community_Detection/Community_Detection_2a_Leiden_Estimate.cypher b/cypher/Community_Detection/Community_Detection_2a_Leiden_Estimate.cypher
@@ -7,7 +7,7 @@ CALL gds.beta.leiden.write.estimate(
   tolerance: 0.0000001,
   consecutiveIds: true,
   relationshipWeightProperty: $dependencies_projection_weight_property,
-  writeProperty: 'leidenCommunityId'
+  writeProperty: $dependencies_projection_write_property
 })
 YIELD nodeCount
      ,relationshipCount

diff --git a/cypher/Community_Detection/Community_Detection_2c_Leiden_Mutate.cypher b/cypher/Community_Detection/Community_Detection_2c_Leiden_Mutate.cypher
@@ -0,0 +1,38 @@
+// Community Detection Leiden Mutate
+
+CALL gds.leiden.mutate(
+ $dependencies_projection + '-without-empty', {
+    tolerance: 0.00001,
+    consecutiveIds: NOT toBoolean($dependencies_include_intermediate_communities),
+    includeIntermediateCommunities: toBoolean($dependencies_include_intermediate_communities),
+    relationshipWeightProperty: $dependencies_projection_weight_property,
+    mutateProperty: $dependencies_projection_write_property
+})
+ YIELD communityCount
+      ,nodePropertiesWritten
+      ,ranLevels
+      ,modularity
+      ,modularities
+      ,preProcessingMillis
+      ,computeMillis
+      ,mutateMillis
+      ,postProcessingMillis
+      ,communityDistribution
+RETURN communityCount
+      ,nodePropertiesWritten
+      ,ranLevels
+      ,modularity
+      ,modularities
+      ,preProcessingMillis
+      ,computeMillis
+      ,mutateMillis
+      ,postProcessingMillis
+      ,communityDistribution.min
+      ,communityDistribution.mean
+      ,communityDistribution.max
+      ,communityDistribution.p50
+      ,communityDistribution.p75
+      ,communityDistribution.p90
+      ,communityDistribution.p95
+      ,communityDistribution.p99
+      ,communityDistribution.p999
diff --git a/...mmunity_Detection_2c_Leiden_Stream.cypher → ...mmunity_Detection_2d_Leiden_Stream.cypher b/...mmunity_Detection_2c_Leiden_Stream.cypher → ...mmunity_Detection_2d_Leiden_Stream.cypher
diff --git a/cypher/Community_Detection/Community_Detection_2d_Leiden_Write_Node_Property.cypher b/cypher/Community_Detection/Community_Detection_2d_Leiden_Write_Node_Property.cypher
@@ -1,4 +1,4 @@
-//Community Detection Leiden Write property leidenCommunityId
+//Community Detection Leiden Write property communityLeidenId
 
 CALL gds.beta.leiden.write(
  $dependencies_projection + '-without-empty', {
@@ -7,7 +7,7 @@ CALL gds.beta.leiden.write(
   tolerance: 0.0000001,
   consecutiveIds: true,
   relationshipWeightProperty: $dependencies_projection_weight_property,
-  writeProperty: 'leidenCommunityId'
+  writeProperty: 'communityLeidenId'
 })
 YIELD preProcessingMillis
      ,computeMillis

diff --git a/cypher/Community_Detection/Community_Detection_2e_Leiden_Label_Delete.cypher b/cypher/Community_Detection/Community_Detection_2e_Leiden_Label_Delete.cypher
diff --git a/cypher/Community_Detection/Community_Detection_2f_Leiden_Label.cypher b/cypher/Community_Detection/Community_Detection_2f_Leiden_Label.cypher
diff --git a/cypher/Community_Detection/Community_Detection_3a_WeaklyConnectedComponents_Estimate.cypher b/cypher/Community_Detection/Community_Detection_3a_WeaklyConnectedComponents_Estimate.cypher
@@ -2,9 +2,9 @@
 
 CALL gds.labelPropagation.write.estimate(
  $dependencies_projection + '-without-empty', {
-  relationshipWeightProperty: $dependencies_projection_weight_property,
-  consecutiveIds: true,
-  writeProperty: 'labelPropagationCommunityId'
+      relationshipWeightProperty: $dependencies_projection_weight_property
+     ,writeProperty: $dependencies_projection_write_property
+     ,consecutiveIds: true
 })
  YIELD requiredMemory
       ,nodeCount

diff --git a/...er/Community_Detection/Community_Detection_3b_WeaklyConnectedComponents_Statistics.cypher b/...er/Community_Detection/Community_Detection_3b_WeaklyConnectedComponents_Statistics.cypher
@@ -2,8 +2,8 @@
 
 CALL gds.wcc.stats(
  $dependencies_projection + '-without-empty', {
-  relationshipWeightProperty: $dependencies_projection_weight_property,
-  consecutiveIds: true
+      relationshipWeightProperty: $dependencies_projection_weight_property
+     ,consecutiveIds: true
 })
  YIELD componentCount
       ,preProcessingMillis

diff --git a/cypher/Community_Detection/Community_Detection_3c_WeaklyConnectedComponents_Mutate.cypher b/cypher/Community_Detection/Community_Detection_3c_WeaklyConnectedComponents_Mutate.cypher
@@ -0,0 +1,30 @@
+// Community Detection Weakly Connected Components Mutate
+
+CALL gds.wcc.mutate(
+ $dependencies_projection + '-without-empty', {
+      relationshipWeightProperty: $dependencies_projection_weight_property
+     ,mutateProperty: $dependencies_projection_write_property
+     ,consecutiveIds: true
+})
+ YIELD componentCount
+      ,nodePropertiesWritten
+      ,preProcessingMillis
+      ,computeMillis
+      ,mutateMillis
+      ,postProcessingMillis
+      ,componentDistribution
+RETURN componentCount
+      ,nodePropertiesWritten
+      ,preProcessingMillis
+      ,computeMillis
+      ,mutateMillis
+      ,postProcessingMillis
+      ,componentDistribution.min
+      ,componentDistribution.mean
+      ,componentDistribution.max
+      ,componentDistribution.p50
+      ,componentDistribution.p75
+      ,componentDistribution.p90
+      ,componentDistribution.p95
+      ,componentDistribution.p99
+      ,componentDistribution.p999
diff --git a/...c_WeaklyConnectedComponents_Stream.cypher → ...d_WeaklyConnectedComponents_Stream.cypher b/...c_WeaklyConnectedComponents_Stream.cypher → ...d_WeaklyConnectedComponents_Stream.cypher
diff --git a/.../Community_Detection/Community_Detection_3e_WeaklyConnectedComponents_Label_Delete.cypher b/.../Community_Detection/Community_Detection_3e_WeaklyConnectedComponents_Label_Delete.cypher
diff --git a/...3d_WeaklyConnectedComponents_Write.cypher → ...3e_WeaklyConnectedComponents_Write.cypher b/...3d_WeaklyConnectedComponents_Write.cypher → ...3e_WeaklyConnectedComponents_Write.cypher
@@ -1,10 +1,10 @@
-// Community Detection Weakly Connected Components write node property weaklyConnectedComponentId
+// Community Detection Weakly Connected Components write node property communityWeaklyConnectedComponentId
 
 CALL gds.wcc.write(
  $dependencies_projection + '-without-empty', {
        relationshipWeightProperty: $dependencies_projection_weight_property
       ,consecutiveIds: true
-      ,writeProperty: 'weaklyConnectedComponentId'
+      ,writeProperty: 'communityWeaklyConnectedComponentId'
 })
 YIELD componentCount
      ,preProcessingMillis

diff --git a/cypher/Community_Detection/Community_Detection_3f_WeaklyConnectedComponents_Label.cypher b/cypher/Community_Detection/Community_Detection_3f_WeaklyConnectedComponents_Label.cypher
diff --git a/cypher/Community_Detection/Community_Detection_4a_Label_Propagation_Estimate.cypher b/cypher/Community_Detection/Community_Detection_4a_Label_Propagation_Estimate.cypher
@@ -3,8 +3,8 @@
 CALL gds.labelPropagation.write.estimate(
  $dependencies_projection + '-without-empty', {
      relationshipWeightProperty: $dependencies_projection_weight_property
+    ,writeProperty: $dependencies_projection_write_property
     ,consecutiveIds: true
-    ,writeProperty: 'labelPropagationCommunityId'
 })
  YIELD requiredMemory
       ,nodeCount

diff --git a/cypher/Community_Detection/Community_Detection_4c_Label_Propagation_Mutate.cypher b/cypher/Community_Detection/Community_Detection_4c_Label_Propagation_Mutate.cypher
@@ -0,0 +1,34 @@
+// Community Detection Label Propagation Mutate
+
+CALL gds.labelPropagation.mutate(
+ $dependencies_projection + '-without-empty', {
+     relationshipWeightProperty: $dependencies_projection_weight_property
+    ,mutateProperty: $dependencies_projection_write_property
+    ,consecutiveIds: true
+})
+YIELD ranIterations
+     ,didConverge
+     ,communityCount
+     ,preProcessingMillis
+     ,computeMillis
+     ,mutateMillis
+     ,postProcessingMillis
+     ,nodePropertiesWritten
+     ,communityDistribution
+RETURN ranIterations
+      ,didConverge
+      ,communityCount
+      ,preProcessingMillis
+      ,computeMillis
+      ,mutateMillis
+      ,postProcessingMillis
+      ,nodePropertiesWritten
+      ,communityDistribution.min
+      ,communityDistribution.mean
+      ,communityDistribution.max
+      ,communityDistribution.p50
+      ,communityDistribution.p75
+      ,communityDistribution.p90
+      ,communityDistribution.p95
+      ,communityDistribution.p99
+      ,communityDistribution.p999
diff --git a/...ection_4c_Label_Propagation_Stream.cypher → ...ection_4d_Label_Propagation_Stream.cypher b/...ection_4c_Label_Propagation_Stream.cypher → ...ection_4d_Label_Propagation_Stream.cypher
diff --git a/...tection_4d_Label_Propagation_Write.cypher → ...tection_4e_Label_Propagation_Write.cypher b/...tection_4d_Label_Propagation_Write.cypher → ...tection_4e_Label_Propagation_Write.cypher
@@ -1,10 +1,10 @@
-// Community Detection Label Propagation write node property labelPropagationCommunityId
+// Community Detection Label Propagation write node property communityLabelPropagationId
 
 CALL gds.labelPropagation.write(
  $dependencies_projection + '-without-empty', {
      relationshipWeightProperty: $dependencies_projection_weight_property
     ,consecutiveIds: true
-    ,writeProperty: 'labelPropagationCommunityId'
+    ,writeProperty: 'communityLabelPropagationId'
 })
 YIELD ranIterations
      ,didConverge

diff --git a/cypher/Community_Detection/Community_Detection_4f_Label_Propagation_Label.cypher b/cypher/Community_Detection/Community_Detection_4f_Label_Propagation_Label.cypher