Skip to content
This repository was archived by the owner on Apr 22, 2020. It is now read-only.

Commit 5be6120

Browse files
mknblchjexp
authored andcommitted
[WIP] Default triangle proc change (#435)
Default triangle proc change
1 parent bebd9c3 commit 5be6120

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

algo/src/main/java/org/neo4j/graphalgo/TriangleProc.java

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -68,8 +68,8 @@ public Stream<TriangleStream.Result> triangleStream(
6868
return triangleStream.resultStream();
6969
}
7070

71-
@Procedure("algo.triangleCount.stream")
72-
@Description("CALL algo.triangleCount.stream(label, relationship, {concurrency:4}) " +
71+
@Procedure("algo.triangleCount.exp1.stream")
72+
@Description("CALL algo.triangleCount.exp1.stream(label, relationship, {concurrency:4}) " +
7373
"YIELD nodeId, triangles - yield nodeId, number of triangles")
7474
public Stream<TriangleCount.Result> triangleCountStream(
7575
@Name(value = "label", defaultValue = "") String label,
@@ -97,7 +97,7 @@ public Stream<TriangleCount.Result> triangleCountStream(
9797
return triangleCount.resultStream();
9898
}
9999

100-
@Procedure("algo.triangleCount.exp1.stream")
100+
@Procedure("algo.triangleCount.stream")
101101
@Description("CALL algo.triangleCount.stream(label, relationship, {concurrency:8}) " +
102102
"YIELD nodeId, triangles - yield nodeId, number of triangles")
103103
public Stream<TriangleCountExp.Result> triangleCountExp1Stream(
@@ -126,8 +126,8 @@ public Stream<TriangleCountExp.Result> triangleCountExp1Stream(
126126
return triangleCount.resultStream();
127127
}
128128

129-
@Procedure(value = "algo.triangleCount", mode = Mode.WRITE)
130-
@Description("CALL algo.triangleCount(label, relationship, " +
129+
@Procedure(value = "algo.triangleCount.exp1", mode = Mode.WRITE)
130+
@Description("CALL algo.triangleCount.exp1(label, relationship, " +
131131
"{concurrency:4, write:true, writeProperty:'triangles', clusteringCoefficientProperty:'coefficient'}) " +
132132
"YIELD loadMillis, computeMillis, writeMillis, nodeCount, triangleCount, averageClusteringCoefficient")
133133
public Stream<Result> triangleCount(
@@ -197,7 +197,7 @@ public Stream<Result> triangleCount(
197197
return Stream.of(builder.build());
198198
}
199199

200-
@Procedure(value = "algo.triangleCount.exp1", mode = Mode.WRITE)
200+
@Procedure(value = "algo.triangleCount", mode = Mode.WRITE)
201201
@Description("CALL algo.triangleCount(label, relationship, " +
202202
"{concurrency:8, write:true, writeProperty:'triangles', clusteringCoefficientProperty:'coefficient'}) " +
203203
"YIELD loadMillis, computeMillis, writeMillis, nodeCount, triangleCount, averageClusteringCoefficient")
@@ -207,7 +207,7 @@ public Stream<Result> triangleCountExp1(
207207
@Name(value = "config", defaultValue = "{}") Map<String, Object> config) {
208208

209209
final Graph graph;
210-
final TriangleCount triangleCount;
210+
final TriangleCountExp triangleCount;
211211
final double[] clusteringCoefficients;
212212

213213
final ProcedureConfiguration configuration = ProcedureConfiguration.create(config)
@@ -228,7 +228,7 @@ public Stream<Result> triangleCountExp1(
228228

229229
final TerminationFlag terminationFlag = TerminationFlag.wrap(transaction);
230230
try (ProgressTimer timer = builder.timeEval()) {
231-
triangleCount = new TriangleCount(graph, Pools.DEFAULT, configuration.getConcurrency())
231+
triangleCount = new TriangleCountExp(graph, Pools.DEFAULT, configuration.getConcurrency())
232232
.withProgressLogger(ProgressLogger.wrap(log, "triangleCount"))
233233
.withTerminationFlag(terminationFlag)
234234
.compute();

0 commit comments

Comments
 (0)