Parametrize Centrality algorithm reports

JohT · JohT · commit b6c74d694cd3 · 2023-09-22T21:29:41.000+02:00
diff --git a/cypher/Centrality/Centrality_0_Delete_Projection.cypher b/cypher/Centrality/Centrality_0_Delete_Projection.cypher
diff --git a/cypher/Centrality/Centrality_0b_Delete_Subraph_Projection.cypher b/cypher/Centrality/Centrality_0b_Delete_Subraph_Projection.cypher
diff --git a/cypher/Centrality/Centrality_1_Create_Projection.cypher b/cypher/Centrality/Centrality_1_Create_Projection.cypher
diff --git a/cypher/Centrality/Centrality_1b_Create_Subgraph_Without_Empty_Packages.cypher b/cypher/Centrality/Centrality_1b_Create_Subgraph_Without_Empty_Packages.cypher
diff --git a/cypher/Centrality/Centrality_2a_Page_Rank_Estimate_Memory.cypher b/cypher/Centrality/Centrality_2a_Page_Rank_Estimate_Memory.cypher
@@ -1,11 +1,12 @@
 //Centrality 2a Page Rank Estimate Memory
 
-CALL gds.pageRank.write.estimate('package-centrality-without-empty', {
+CALL gds.pageRank.write.estimate(
+ $dependencies_projection + '-without-empty', {
    writeProperty: 'pageRank'
   ,maxIterations: 50
   ,dampingFactor: 0.85
   ,tolerance: 0.00000001
-  ,relationshipWeightProperty: 'weight25PercentInterfaces'
+  ,relationshipWeightProperty: $dependencies_projection_weight_property
   ,scaler: "L1Norm"
 })
  YIELD nodeCount, relationshipCount, bytesMin, bytesMax, heapPercentageMin, heapPercentageMax, treeView
diff --git a/cypher/Centrality/Centrality_2b_Page_Rank_Statistics.cypher b/cypher/Centrality/Centrality_2b_Page_Rank_Statistics.cypher
@@ -1,10 +1,11 @@
 //Centrality 2b Page Rank Statistics
 
-CALL gds.pageRank.stats('package-centrality-without-empty', {
+CALL gds.pageRank.stats(
+ $dependencies_projection + '-without-empty', {
    maxIterations: 50
   ,dampingFactor: 0.85
   ,tolerance: 0.00000001
-  ,relationshipWeightProperty: 'weight25PercentInterfaces'
+  ,relationshipWeightProperty: $dependencies_projection_weight_property
   ,scaler: "L1Norm"
 })
  YIELD ranIterations
diff --git a/cypher/Centrality/Centrality_3c_Page_Rank_Stream.cypher b/cypher/Centrality/Centrality_3c_Page_Rank_Stream.cypher
@@ -1,17 +1,17 @@
 //Centrality 3c Page Rank Stream
 
-CALL gds.pageRank.stream('package-centrality-without-empty', {
+CALL gds.pageRank.stream(
+ $dependencies_projection + '-without-empty', {
    maxIterations: 50
   ,dampingFactor: 0.85
   ,tolerance: 0.00000001
-  ,relationshipWeightProperty: 'weight25PercentInterfaces'
+  ,relationshipWeightProperty: $dependencies_projection_weight_property
   ,scaler: "L2Norm"
 })
  YIELD nodeId, score
-  WITH gds.util.asNode(nodeId) AS package, score
-RETURN package.fqn                  AS fullQualifiedPackageName
-      ,package.name                 AS packageName
+  WITH gds.util.asNode(nodeId) AS member, score
+RETURN coalesce(member.fqn, member.fileName, member.name) AS memberName
       ,score
-      ,package.incomingDependencies AS incomingDependencies
-      ,package.outgoingDependencies AS outgoingDependencies
- ORDER BY score DESC, packageName ASC
+      ,member.incomingDependencies AS incomingDependencies
+      ,member.outgoingDependencies AS outgoingDependencies
+ ORDER BY score DESC, memberName ASC
diff --git a/cypher/Centrality/Centrality_3d_Page_Rank_Write.cypher b/cypher/Centrality/Centrality_3d_Page_Rank_Write.cypher
@@ -1,12 +1,13 @@
 //Centrality 3d Page Rank Write
 
-CALL gds.pageRank.write('package-centrality-without-empty', {
+CALL gds.pageRank.write(
+ $dependencies_projection + '-without-empty', {
    maxIterations: 50
   ,dampingFactor: 0.85
   ,tolerance: 0.00000001
-  ,relationshipWeightProperty: 'weight25PercentInterfaces'
+  ,relationshipWeightProperty: $dependencies_projection_weight_property
   ,scaler: "L2Norm"
-  ,writeProperty: "pageRank25PercentInterfaces"
+  ,writeProperty: "pageRank"
 })
  YIELD nodePropertiesWritten
       ,ranIterations
diff --git a/cypher/Centrality/Centrality_4a_Article_Rank_Estimate_Memory.cypher b/cypher/Centrality/Centrality_4a_Article_Rank_Estimate_Memory.cypher
@@ -1,10 +1,11 @@
 //Centrality 4a Article Rank Estimate Memory
-CALL gds.articleRank.write.estimate('package-centrality-without-empty', {
+CALL gds.articleRank.write.estimate(
+  $dependencies_projection + '-without-empty', {
    writeProperty: 'articleRank'
   ,maxIterations: 30
   ,dampingFactor: 0.85
   ,tolerance: 0.00000001
-  ,relationshipWeightProperty: 'weight25PercentInterfaces'
+  ,relationshipWeightProperty: $dependencies_projection_weight_property
   ,scaler: "L1Norm"
 })
  YIELD nodeCount, relationshipCount, bytesMin, bytesMax, heapPercentageMin, heapPercentageMax, treeView
diff --git a/cypher/Centrality/Centrality_4b_Article_Rank_Statistics.cypher b/cypher/Centrality/Centrality_4b_Article_Rank_Statistics.cypher
@@ -1,9 +1,10 @@
 //Centrality 4b Article Rank Statistics
-CALL gds.articleRank.stats('package-centrality-without-empty', {
+CALL gds.articleRank.stats(
+ $dependencies_projection + '-without-empty', {
    maxIterations: 30
   ,dampingFactor: 0.85
   ,tolerance: 0.00000001
-  ,relationshipWeightProperty: 'weight25PercentInterfaces'
+  ,relationshipWeightProperty: $dependencies_projection_weight_property
   ,scaler: "L1Norm"
 })
  YIELD ranIterations
diff --git a/cypher/Centrality/Centrality_4c_Article_Rank_Stream.cypher b/cypher/Centrality/Centrality_4c_Article_Rank_Stream.cypher
@@ -1,17 +1,17 @@
 //Centrality 4c Article Rank Stream
 
-CALL gds.articleRank.stream('package-centrality-without-empty', {
+CALL gds.articleRank.stream(
+ $dependencies_projection + '-without-empty', {
    maxIterations: 30
   ,dampingFactor: 0.85
   ,tolerance: 0.00000001
-  ,relationshipWeightProperty: 'weight25PercentInterfaces'
+  ,relationshipWeightProperty: $dependencies_projection_weight_property
   ,scaler: "L2Norm"
 })
  YIELD nodeId, score
-  WITH gds.util.asNode(nodeId) AS package, score
-RETURN package.fqn                  AS fullQualifiedPackageName
-      ,package.name                 AS packageName
+  WITH gds.util.asNode(nodeId) AS member, score
+RETURN coalesce(member.fqn, member.fileName, member.name) AS memberName
       ,score
-      ,package.incomingDependencies AS incomingDependencies
-      ,package.outgoingDependencies AS outgoingDependencies
- ORDER BY score DESC, packageName ASC
+      ,member.incomingDependencies AS incomingDependencies
+      ,member.outgoingDependencies AS outgoingDependencies
+ ORDER BY score DESC, memberName ASC
diff --git a/cypher/Centrality/Centrality_4d_Article_Rank_Write.cypher b/cypher/Centrality/Centrality_4d_Article_Rank_Write.cypher
@@ -1,12 +1,13 @@
 //Centrality 4d Article Rank Write
 
-CALL gds.articleRank.write('package-centrality-without-empty', {
+CALL gds.articleRank.write(
+ $dependencies_projection + '-without-empty', {
    maxIterations: 50
   ,dampingFactor: 0.85
   ,tolerance: 0.00000001
-  ,relationshipWeightProperty: 'weight25PercentInterfaces'
+  ,relationshipWeightProperty: $dependencies_projection_weight_property
   ,scaler: "L2Norm"
-  ,writeProperty: "articleRank25PercentInterfaces"
+  ,writeProperty: "articleRank"
 })
 YIELD nodePropertiesWritten
      ,ranIterations
diff --git a/cypher/Centrality/Centrality_5a_Betweeness_Estimate.cypher b/cypher/Centrality/Centrality_5a_Betweeness_Estimate.cypher
@@ -1,7 +1,9 @@
 //Centrality 5a Betweeness Estimate
 
-CALL gds.betweenness.write.estimate('package-centrality-without-empty', { 
-    writeProperty: 'betweenness' 
+CALL gds.betweenness.write.estimate(
+ $dependencies_projection + '-without-empty', {
+     relationshipWeightProperty: $dependencies_projection_weight_property
+    ,writeProperty: 'centralityBetweenness' 
 })
  YIELD nodeCount, relationshipCount, bytesMin, bytesMax, heapPercentageMin, heapPercentageMax, treeView
 RETURN nodeCount, relationshipCount, bytesMin, bytesMax, heapPercentageMin, heapPercentageMax, treeView
diff --git a/cypher/Centrality/Centrality_5b_Betweeness_Statistics.cypher b/cypher/Centrality/Centrality_5b_Betweeness_Statistics.cypher
@@ -1,7 +1,8 @@
 //Centrality 5b Betweeness Statistics
 
- CALL gds.betweenness.stats('package-centrality-without-empty', {
-     relationshipWeightProperty: 'weight25PercentInterfaces'
+ CALL gds.betweenness.stats(
+  $dependencies_projection + '-without-empty', {
+     relationshipWeightProperty: $dependencies_projection_weight_property
     })
  YIELD preProcessingMillis
       ,computeMillis
diff --git a/cypher/Centrality/Centrality_5c_Betweeness_Stream.cypher b/cypher/Centrality/Centrality_5c_Betweeness_Stream.cypher
@@ -1,13 +1,13 @@
 // Centrality 5c Betweeness Stream
 
-CALL gds.betweenness.stream('package-centrality-without-empty', {
-   relationshipWeightProperty: 'weight25PercentInterfaces'
+CALL gds.betweenness.stream(
+ $dependencies_projection + '-without-empty', {
+   relationshipWeightProperty: $dependencies_projection_weight_property
 })
  YIELD nodeId, score
-  WITH gds.util.asNode(nodeId) AS package, score
-RETURN package.fqn                  AS fullQualifiedPackageName
-      ,package.name                 AS packageName
+  WITH gds.util.asNode(nodeId) AS member, score
+RETURN coalesce(member.fqn, member.fileName, member.name) AS memberName
       ,score
-      ,package.incomingDependencies AS incomingDependencies
-      ,package.outgoingDependencies AS outgoingDependencies
- ORDER BY score DESC, packageName ASC
+      ,member.incomingDependencies AS incomingDependencies
+      ,member.outgoingDependencies AS outgoingDependencies
+ ORDER BY score DESC, memberName ASC
diff --git a/cypher/Centrality/Centrality_5d_Betweeness_Write.cypher b/cypher/Centrality/Centrality_5d_Betweeness_Write.cypher
@@ -1,8 +1,9 @@
 // Centrality 5d Betweeness Write
 
-CALL gds.betweenness.write('package-centrality-without-empty', {
-   relationshipWeightProperty: 'weight25PercentInterfaces',
-   writeProperty: 'betweenness25PercentInterfaces'
+CALL gds.betweenness.write(
+ $dependencies_projection + '-without-empty', {
+   relationshipWeightProperty: $dependencies_projection_weight_property,
+   writeProperty: 'centralityBetweenness'
 })
 YIELD nodePropertiesWritten
      ,preProcessingMillis
diff --git a/cypher/Centrality/Centrality_6a_Cost_effective_Lazy_Forward_CELF_Estimate.cypher b/cypher/Centrality/Centrality_6a_Cost_effective_Lazy_Forward_CELF_Estimate.cypher
@@ -0,0 +1,9 @@
+// Centrality 6c Cost-effective Lazy Forward (CELF) Estimate
+
+  CALL gds.beta.influenceMaximization.celf.write.estimate(
+ $dependencies_projection + '-without-empty', {
+     seedSetSize: 5
+    ,writeProperty: 'centralityCostEffectiveLazyForward'
+})
+ YIELD nodeCount, relationshipCount, bytesMin, bytesMax, heapPercentageMin, heapPercentageMax, treeView
+RETURN nodeCount, relationshipCount, bytesMin, bytesMax, heapPercentageMin, heapPercentageMax, treeView
diff --git a/cypher/Centrality/Centrality_6b_Cost_effective_Lazy_Forward_CELF_Statistics.cypher b/cypher/Centrality/Centrality_6b_Cost_effective_Lazy_Forward_CELF_Statistics.cypher
@@ -0,0 +1,12 @@
+// Centrality 6b Cost-effective Lazy Forward (CELF) Estimate
+
+CALL gds.beta.influenceMaximization.celf.stats(
+  $dependencies_projection + '-without-empty', {
+    seedSetSize: 5
+  })
+ YIELD computeMillis
+      ,totalSpread
+      ,nodeCount
+RETURN computeMillis
+      ,totalSpread
+      ,nodeCount
diff --git a/cypher/Centrality/Centrality_6c_Cost_effective_Lazy_Forward_CELF_Stream.cypher b/cypher/Centrality/Centrality_6c_Cost_effective_Lazy_Forward_CELF_Stream.cypher
@@ -1,11 +1,13 @@
-//Centrality 6c Cost-effective Lazy Forward (CELF) Stream
+// Centrality 6c Cost-effective Lazy Forward (CELF) Stream
 
-  CALL gds.beta.influenceMaximization.celf.stream('package-centrality-without-empty', {seedSetSize: 5})
+  CALL gds.beta.influenceMaximization.celf.stream(
+   $dependencies_projection + '-without-empty', {
+      seedSetSize: 5
+ })
  YIELD nodeId, spread
-  WITH gds.util.asNode(nodeId) AS package, spread
-RETURN package.fqn                  AS fullQualifiedPackageName
-      ,package.name                 AS packageName
+  WITH gds.util.asNode(nodeId) AS member, spread
+RETURN coalesce(member.fqn, member.fileName, member.name) AS memberName
       ,spread
-      ,package.incomingDependencies AS incomingDependencies
-      ,package.outgoingDependencies AS outgoingDependencies
- ORDER BY spread DESC, packageName ASC
+      ,member.incomingDependencies AS incomingDependencies
+      ,member.outgoingDependencies AS outgoingDependencies
+ ORDER BY spread DESC, memberName ASC
diff --git a/cypher/Centrality/Centrality_6d_Cost_effective_Lazy_Forward_CELF_Write.cypher b/cypher/Centrality/Centrality_6d_Cost_effective_Lazy_Forward_CELF_Write.cypher
@@ -0,0 +1,17 @@
+// Centrality 6d Cost-effective Lazy Forward (CELF) Write
+
+  CALL gds.beta.influenceMaximization.celf.write(
+    $dependencies_projection + '-without-empty', {
+      seedSetSize: 5
+     ,writeProperty: 'centralityCostEffectiveLazyForward'
+})
+ YIELD writeMillis
+      ,nodePropertiesWritten
+      ,computeMillis
+      ,totalSpread
+      ,nodeCount
+RETURN writeMillis
+      ,nodePropertiesWritten
+      ,computeMillis
+      ,totalSpread
+      ,nodeCount
diff --git a/cypher/Centrality/Centrality_7a_Harmonic_Closeness_Stream.cypher b/cypher/Centrality/Centrality_7a_Harmonic_Closeness_Stream.cypher
@@ -2,10 +2,9 @@
 
 CALL gds.alpha.closeness.harmonic.stream('package-centrality-without-empty', {})
  YIELD nodeId, centrality
-  WITH gds.util.asNode(nodeId) AS package, centrality
-RETURN package.fqn                  AS fullQualifiedPackageName
-      ,package.name                 AS packageName
+  WITH gds.util.asNode(nodeId) AS member, centrality
+RETURN coalesce(member.fqn, member.fileName, member.name) AS memberName
       ,centrality
-      ,package.incomingDependencies AS incomingDependencies
-      ,package.outgoingDependencies AS outgoingDependencies
- ORDER BY centrality DESC, packageName ASC
+      ,member.incomingDependencies AS incomingDependencies
+      ,member.outgoingDependencies AS outgoingDependencies
+ ORDER BY centrality DESC, memberName ASC
diff --git a/cypher/Centrality/Centrality_8b_Closeness_Stream.cypher b/cypher/Centrality/Centrality_8b_Closeness_Stream.cypher
@@ -4,10 +4,9 @@ CALL gds.beta.closeness.stream('package-centrality-without-empty', {
    useWassermanFaust: true
 })
  YIELD nodeId, score
-  WITH gds.util.asNode(nodeId) AS package, score
-RETURN package.fqn                  AS fullQualifiedPackageName
-      ,package.name                 AS packageName
+  WITH gds.util.asNode(nodeId) AS member, score
+RETURN coalesce(member.fqn, member.fileName, member.name) AS memberName
       ,score
-      ,package.incomingDependencies AS incomingDependencies
-      ,package.outgoingDependencies AS outgoingDependencies
- ORDER BY score DESC, packageName ASC
+      ,member.incomingDependencies AS incomingDependencies
+      ,member.outgoingDependencies AS outgoingDependencies
+ ORDER BY score DESC, memberName ASC
diff --git a/scripts/reports/CentralityCsv.sh b/scripts/reports/CentralityCsv.sh
