Skip to content

Commit abab101

Browse files
IoannisPanagiotasIoannisPanagiotas
authored
Merge pull request #9578 from IoannisPanagiotas/mutate-vs-write-step
Separate mutate and write steps
2 parents dd6f1c6 + a0774b0 commit abab101

File tree

97 files changed

+514
-587
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

97 files changed

+514
-587
lines changed

‎applications/algorithms/centrality/src/main/java/org/neo4j/gds/applications/algorithms/centrality/ArticulationPointsMutateStep.java

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -22,15 +22,13 @@
2222
import com.carrotsearch.hppc.BitSet;
2323
import org.neo4j.gds.api.Graph;
2424
import org.neo4j.gds.api.GraphStore;
25-
import org.neo4j.gds.api.ResultStore;
2625
import org.neo4j.gds.api.properties.nodes.LongNodePropertyValues;
2726
import org.neo4j.gds.applications.algorithms.machinery.MutateNodeProperty;
28-
import org.neo4j.gds.applications.algorithms.machinery.MutateOrWriteStep;
27+
import org.neo4j.gds.applications.algorithms.machinery.MutateStep;
2928
import org.neo4j.gds.applications.algorithms.metadata.NodePropertiesWritten;
3029
import org.neo4j.gds.articulationpoints.ArticulationPointsMutateConfig;
31-
import org.neo4j.gds.core.utils.progress.JobId;
3230

33-
class ArticulationPointsMutateStep implements MutateOrWriteStep<BitSet, NodePropertiesWritten> {
31+
class ArticulationPointsMutateStep implements MutateStep<BitSet, NodePropertiesWritten> {
3432
private final MutateNodeProperty mutateNodeProperty;
3533
private final ArticulationPointsMutateConfig configuration;
3634

@@ -43,9 +41,7 @@ class ArticulationPointsMutateStep implements MutateOrWriteStep<BitSet, NodeProp
4341
public NodePropertiesWritten execute(
4442
Graph graph,
4543
GraphStore graphStore,
46-
ResultStore resultStore,
47-
BitSet result,
48-
JobId jobId
44+
BitSet result
4945
) {
5046
var nodeProperties = new LongNodePropertyValues() {
5147
@Override

‎applications/algorithms/centrality/src/main/java/org/neo4j/gds/applications/algorithms/centrality/ArticulationPointsWriteStep.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -24,15 +24,15 @@
2424
import org.neo4j.gds.api.GraphStore;
2525
import org.neo4j.gds.api.ResultStore;
2626
import org.neo4j.gds.api.properties.nodes.LongNodePropertyValues;
27-
import org.neo4j.gds.applications.algorithms.machinery.MutateOrWriteStep;
27+
import org.neo4j.gds.applications.algorithms.machinery.WriteStep;
2828
import org.neo4j.gds.applications.algorithms.machinery.WriteToDatabase;
2929
import org.neo4j.gds.applications.algorithms.metadata.NodePropertiesWritten;
3030
import org.neo4j.gds.articulationpoints.ArticulationPointsWriteConfig;
3131
import org.neo4j.gds.core.utils.progress.JobId;
3232

3333
import static org.neo4j.gds.applications.algorithms.metadata.Algorithm.ArticulationPoints;
3434

35-
class ArticulationPointsWriteStep implements MutateOrWriteStep<BitSet, NodePropertiesWritten> {
35+
class ArticulationPointsWriteStep implements WriteStep<BitSet, NodePropertiesWritten> {
3636
private final ArticulationPointsWriteConfig configuration;
3737
private final WriteToDatabase writeToDatabase;
3838

‎applications/algorithms/centrality/src/main/java/org/neo4j/gds/applications/algorithms/centrality/BetweennessCentralityMutateStep.java

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -21,15 +21,13 @@
2121

2222
import org.neo4j.gds.api.Graph;
2323
import org.neo4j.gds.api.GraphStore;
24-
import org.neo4j.gds.api.ResultStore;
2524
import org.neo4j.gds.applications.algorithms.machinery.MutateNodeProperty;
26-
import org.neo4j.gds.applications.algorithms.machinery.MutateOrWriteStep;
25+
import org.neo4j.gds.applications.algorithms.machinery.MutateStep;
2726
import org.neo4j.gds.applications.algorithms.metadata.NodePropertiesWritten;
2827
import org.neo4j.gds.betweenness.BetweennessCentralityMutateConfig;
2928
import org.neo4j.gds.betweenness.BetwennessCentralityResult;
30-
import org.neo4j.gds.core.utils.progress.JobId;
3129

32-
class BetweennessCentralityMutateStep implements MutateOrWriteStep<BetwennessCentralityResult, NodePropertiesWritten> {
30+
class BetweennessCentralityMutateStep implements MutateStep<BetwennessCentralityResult, NodePropertiesWritten> {
3331
private final MutateNodeProperty mutateNodeProperty;
3432
private final BetweennessCentralityMutateConfig configuration;
3533

@@ -45,9 +43,7 @@ class BetweennessCentralityMutateStep implements MutateOrWriteStep<BetwennessCen
4543
public NodePropertiesWritten execute(
4644
Graph graph,
4745
GraphStore graphStore,
48-
ResultStore resultStore,
49-
BetwennessCentralityResult result,
50-
JobId jobId
46+
BetwennessCentralityResult result
5147
) {
5248
return mutateNodeProperty.mutateNodeProperties(
5349
graph,

‎applications/algorithms/centrality/src/main/java/org/neo4j/gds/applications/algorithms/centrality/BetweennessCentralityWriteStep.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,15 +23,15 @@
2323
import org.neo4j.gds.api.Graph;
2424
import org.neo4j.gds.api.GraphStore;
2525
import org.neo4j.gds.api.ResultStore;
26-
import org.neo4j.gds.applications.algorithms.machinery.MutateOrWriteStep;
26+
import org.neo4j.gds.applications.algorithms.machinery.WriteStep;
2727
import org.neo4j.gds.applications.algorithms.machinery.WriteToDatabase;
2828
import org.neo4j.gds.applications.algorithms.metadata.NodePropertiesWritten;
2929
import org.neo4j.gds.betweenness.BetweennessCentralityWriteConfig;
3030
import org.neo4j.gds.core.utils.progress.JobId;
3131

3232
import static org.neo4j.gds.applications.algorithms.metadata.Algorithm.BetweennessCentrality;
3333

34-
class BetweennessCentralityWriteStep implements MutateOrWriteStep<CentralityAlgorithmResult, NodePropertiesWritten> {
34+
class BetweennessCentralityWriteStep implements WriteStep<CentralityAlgorithmResult, NodePropertiesWritten> {
3535
private final WriteToDatabase writeToDatabase;
3636
private final BetweennessCentralityWriteConfig configuration;
3737

‎applications/algorithms/centrality/src/main/java/org/neo4j/gds/applications/algorithms/centrality/CelfMutateStep.java

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -21,16 +21,14 @@
2121

2222
import org.neo4j.gds.api.Graph;
2323
import org.neo4j.gds.api.GraphStore;
24-
import org.neo4j.gds.api.ResultStore;
2524
import org.neo4j.gds.applications.algorithms.machinery.MutateNodeProperty;
26-
import org.neo4j.gds.applications.algorithms.machinery.MutateOrWriteStep;
25+
import org.neo4j.gds.applications.algorithms.machinery.MutateStep;
2726
import org.neo4j.gds.applications.algorithms.metadata.NodePropertiesWritten;
28-
import org.neo4j.gds.core.utils.progress.JobId;
2927
import org.neo4j.gds.influenceMaximization.CELFNodeProperties;
3028
import org.neo4j.gds.influenceMaximization.CELFResult;
3129
import org.neo4j.gds.influenceMaximization.InfluenceMaximizationMutateConfig;
3230

33-
class CelfMutateStep implements MutateOrWriteStep<CELFResult, NodePropertiesWritten> {
31+
class CelfMutateStep implements MutateStep<CELFResult, NodePropertiesWritten> {
3432
private final MutateNodeProperty mutateNodeProperty;
3533
private final InfluenceMaximizationMutateConfig configuration;
3634

@@ -43,9 +41,7 @@ class CelfMutateStep implements MutateOrWriteStep<CELFResult, NodePropertiesWrit
4341
public NodePropertiesWritten execute(
4442
Graph graph,
4543
GraphStore graphStore,
46-
ResultStore resultStore,
47-
CELFResult result,
48-
JobId jobId
44+
CELFResult result
4945
) {
5046
var nodeProperties = new CELFNodeProperties(result.seedSetNodes(), graph.nodeCount());
5147

‎applications/algorithms/centrality/src/main/java/org/neo4j/gds/applications/algorithms/centrality/CelfWriteStep.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@
2222
import org.neo4j.gds.api.Graph;
2323
import org.neo4j.gds.api.GraphStore;
2424
import org.neo4j.gds.api.ResultStore;
25-
import org.neo4j.gds.applications.algorithms.machinery.MutateOrWriteStep;
25+
import org.neo4j.gds.applications.algorithms.machinery.WriteStep;
2626
import org.neo4j.gds.applications.algorithms.machinery.WriteToDatabase;
2727
import org.neo4j.gds.applications.algorithms.metadata.NodePropertiesWritten;
2828
import org.neo4j.gds.core.utils.progress.JobId;
@@ -32,7 +32,7 @@
3232

3333
import static org.neo4j.gds.applications.algorithms.metadata.Algorithm.CELF;
3434

35-
class CelfWriteStep implements MutateOrWriteStep<CELFResult, NodePropertiesWritten> {
35+
class CelfWriteStep implements WriteStep<CELFResult, NodePropertiesWritten> {
3636
private final WriteToDatabase writeToDatabase;
3737
private final InfluenceMaximizationWriteConfig configuration;
3838

‎applications/algorithms/centrality/src/main/java/org/neo4j/gds/applications/algorithms/centrality/CentralityAlgorithmsMutateModeBusinessFacade.java

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,7 @@ public <RESULT> RESULT articleRank(
7474
) {
7575
var mutateStep = new PageRankMutateStep(mutateNodeProperty, configuration);
7676

77-
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInMutateOrWriteMode(
77+
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInMutateMode(
7878
graphName,
7979
configuration,
8080
ArticleRank,
@@ -92,7 +92,7 @@ public <RESULT> RESULT articulationPoints(
9292
) {
9393
var mutateStep = new ArticulationPointsMutateStep(mutateNodeProperty, configuration);
9494

95-
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInMutateOrWriteMode(
95+
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInMutateMode(
9696
graphName,
9797
configuration,
9898
ArticulationPoints,
@@ -111,7 +111,7 @@ public <RESULT> RESULT betweennessCentrality(
111111
) {
112112
var mutateStep = new BetweennessCentralityMutateStep(mutateNodeProperty, configuration);
113113

114-
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInMutateOrWriteMode(
114+
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInMutateMode(
115115
graphName,
116116
configuration,
117117
BetweennessCentrality,
@@ -129,7 +129,7 @@ public <RESULT> RESULT celf(
129129
) {
130130
var mutateStep = new CelfMutateStep(mutateNodeProperty, configuration);
131131

132-
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInMutateOrWriteMode(
132+
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInMutateMode(
133133
graphName,
134134
configuration,
135135
CELF,
@@ -147,7 +147,7 @@ public <RESULT> RESULT closenessCentrality(
147147
) {
148148
var mutateStep = new ClosenessCentralityMutateStep(mutateNodeProperty, configuration);
149149

150-
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInMutateOrWriteMode(
150+
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInMutateMode(
151151
graphName,
152152
configuration,
153153
ClosenessCentrality,
@@ -165,7 +165,7 @@ public <RESULT> RESULT degreeCentrality(
165165
) {
166166
var mutateStep = new DegreeCentralityMutateStep(mutateNodeProperty, configuration);
167167

168-
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInMutateOrWriteMode(
168+
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInMutateMode(
169169
graphName,
170170
configuration,
171171
DegreeCentrality,
@@ -183,7 +183,7 @@ public <RESULT> RESULT eigenVector(
183183
) {
184184
var mutateStep = new PageRankMutateStep(mutateNodeProperty, configuration);
185185

186-
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInMutateOrWriteMode(
186+
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInMutateMode(
187187
graphName,
188188
configuration,
189189
EigenVector,
@@ -201,7 +201,7 @@ public <RESULT> RESULT harmonicCentrality(
201201
) {
202202
var mutateStep = new HarmonicCentralityMutateStep(mutateNodeProperty, configuration);
203203

204-
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInMutateOrWriteMode(
204+
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInMutateMode(
205205
graphName,
206206
configuration,
207207
HarmonicCentrality,
@@ -219,7 +219,7 @@ public <RESULT> RESULT pageRank(
219219
) {
220220
var mutateStep = new PageRankMutateStep(mutateNodeProperty, configuration);
221221

222-
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInMutateOrWriteMode(
222+
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInMutateMode(
223223
graphName,
224224
configuration,
225225
PageRank,

‎applications/algorithms/centrality/src/main/java/org/neo4j/gds/applications/algorithms/centrality/CentralityAlgorithmsWriteModeBusinessFacade.java

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -93,7 +93,7 @@ public <RESULT> RESULT articleRank(
9393
) {
9494
var writeStep = new PageRankWriteStep(writeToDatabase, configuration, ArticleRank);
9595

96-
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInMutateOrWriteMode(
96+
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInWriteMode(
9797
graphName,
9898
configuration,
9999
ArticleRank,
@@ -111,7 +111,7 @@ public <RESULT> RESULT betweennessCentrality(
111111
) {
112112
var writeStep = new BetweennessCentralityWriteStep(writeToDatabase, configuration);
113113

114-
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInMutateOrWriteMode(
114+
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInWriteMode(
115115
graphName,
116116
configuration,
117117
BetweennessCentrality,
@@ -127,7 +127,7 @@ public <RESULT> RESULT articulationPoints(
127127
ArticulationPointsWriteConfig configuration,
128128
ResultBuilder<ArticulationPointsWriteConfig, BitSet, RESULT, NodePropertiesWritten> resultBuilder
129129
) {
130-
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInMutateOrWriteMode(
130+
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInWriteMode(
131131
graphName,
132132
configuration,
133133
ArticulationPoints,
@@ -145,7 +145,7 @@ public <CONFIGURATION extends InfluenceMaximizationWriteConfig, RESULT> RESULT c
145145
) {
146146
var writeStep = new CelfWriteStep(writeToDatabase, configuration);
147147

148-
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInMutateOrWriteMode(
148+
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInWriteMode(
149149
graphName,
150150
configuration,
151151
CELF,
@@ -163,7 +163,7 @@ public <RESULT> RESULT closenessCentrality(
163163
) {
164164
var writeStep = new ClosenessCentralityWriteStep(writeToDatabase, configuration);
165165

166-
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInMutateOrWriteMode(
166+
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInWriteMode(
167167
graphName,
168168
configuration,
169169
ClosenessCentrality,
@@ -181,7 +181,7 @@ public <RESULT> RESULT degreeCentrality(
181181
) {
182182
var writeStep = new DegreeCentralityWriteStep(writeToDatabase, configuration);
183183

184-
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInMutateOrWriteMode(
184+
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInWriteMode(
185185
graphName,
186186
configuration,
187187
DegreeCentrality,
@@ -199,7 +199,7 @@ public <RESULT> RESULT eigenvector(
199199
) {
200200
var writeStep = new PageRankWriteStep(writeToDatabase, configuration, EigenVector);
201201

202-
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInMutateOrWriteMode(
202+
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInWriteMode(
203203
graphName,
204204
configuration,
205205
EigenVector,
@@ -217,7 +217,7 @@ public <CONFIGURATION extends HarmonicCentralityWriteConfig, RESULT> RESULT harm
217217
) {
218218
var writeStep = new HarmonicCentralityWriteStep(writeToDatabase, configuration);
219219

220-
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInMutateOrWriteMode(
220+
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInWriteMode(
221221
graphName,
222222
configuration,
223223
HarmonicCentrality,
@@ -235,7 +235,7 @@ public <RESULT> RESULT pageRank(
235235
) {
236236
var writeStep = new PageRankWriteStep(writeToDatabase, configuration, ArticleRank);
237237

238-
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInMutateOrWriteMode(
238+
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInWriteMode(
239239
graphName,
240240
configuration,
241241
PageRank,

‎applications/algorithms/centrality/src/main/java/org/neo4j/gds/applications/algorithms/centrality/ClosenessCentralityMutateStep.java

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -21,15 +21,13 @@
2121

2222
import org.neo4j.gds.api.Graph;
2323
import org.neo4j.gds.api.GraphStore;
24-
import org.neo4j.gds.api.ResultStore;
2524
import org.neo4j.gds.applications.algorithms.machinery.MutateNodeProperty;
26-
import org.neo4j.gds.applications.algorithms.machinery.MutateOrWriteStep;
25+
import org.neo4j.gds.applications.algorithms.machinery.MutateStep;
2726
import org.neo4j.gds.applications.algorithms.metadata.NodePropertiesWritten;
2827
import org.neo4j.gds.closeness.ClosenessCentralityMutateConfig;
2928
import org.neo4j.gds.closeness.ClosenessCentralityResult;
30-
import org.neo4j.gds.core.utils.progress.JobId;
3129

32-
class ClosenessCentralityMutateStep implements MutateOrWriteStep<ClosenessCentralityResult, NodePropertiesWritten> {
30+
class ClosenessCentralityMutateStep implements MutateStep<ClosenessCentralityResult, NodePropertiesWritten> {
3331
private final MutateNodeProperty mutateNodeProperty;
3432
private final ClosenessCentralityMutateConfig configuration;
3533

@@ -45,9 +43,7 @@ class ClosenessCentralityMutateStep implements MutateOrWriteStep<ClosenessCentra
4543
public NodePropertiesWritten execute(
4644
Graph graph,
4745
GraphStore graphStore,
48-
ResultStore resultStore,
49-
ClosenessCentralityResult result,
50-
JobId jobId
46+
ClosenessCentralityResult result
5147
) {
5248
return mutateNodeProperty.mutateNodeProperties(
5349
graph,

‎applications/algorithms/centrality/src/main/java/org/neo4j/gds/applications/algorithms/centrality/ClosenessCentralityWriteStep.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,15 +23,15 @@
2323
import org.neo4j.gds.api.Graph;
2424
import org.neo4j.gds.api.GraphStore;
2525
import org.neo4j.gds.api.ResultStore;
26-
import org.neo4j.gds.applications.algorithms.machinery.MutateOrWriteStep;
26+
import org.neo4j.gds.applications.algorithms.machinery.WriteStep;
2727
import org.neo4j.gds.applications.algorithms.machinery.WriteToDatabase;
2828
import org.neo4j.gds.applications.algorithms.metadata.NodePropertiesWritten;
2929
import org.neo4j.gds.closeness.ClosenessCentralityWriteConfig;
3030
import org.neo4j.gds.core.utils.progress.JobId;
3131

3232
import static org.neo4j.gds.applications.algorithms.metadata.Algorithm.ClosenessCentrality;
3333

34-
class ClosenessCentralityWriteStep implements MutateOrWriteStep<CentralityAlgorithmResult, NodePropertiesWritten> {
34+
class ClosenessCentralityWriteStep implements WriteStep<CentralityAlgorithmResult, NodePropertiesWritten> {
3535
private final WriteToDatabase writeToDatabase;
3636
private final ClosenessCentralityWriteConfig configuration;
3737

‎applications/algorithms/centrality/src/main/java/org/neo4j/gds/applications/algorithms/centrality/DegreeCentralityMutateStep.java

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -21,15 +21,13 @@
2121

2222
import org.neo4j.gds.api.Graph;
2323
import org.neo4j.gds.api.GraphStore;
24-
import org.neo4j.gds.api.ResultStore;
2524
import org.neo4j.gds.applications.algorithms.machinery.MutateNodeProperty;
26-
import org.neo4j.gds.applications.algorithms.machinery.MutateOrWriteStep;
25+
import org.neo4j.gds.applications.algorithms.machinery.MutateStep;
2726
import org.neo4j.gds.applications.algorithms.metadata.NodePropertiesWritten;
28-
import org.neo4j.gds.core.utils.progress.JobId;
2927
import org.neo4j.gds.degree.DegreeCentralityMutateConfig;
3028
import org.neo4j.gds.degree.DegreeCentralityResult;
3129

32-
class DegreeCentralityMutateStep implements MutateOrWriteStep<DegreeCentralityResult, NodePropertiesWritten> {
30+
class DegreeCentralityMutateStep implements MutateStep<DegreeCentralityResult, NodePropertiesWritten> {
3331
private final MutateNodeProperty mutateNodeProperty;
3432
private final DegreeCentralityMutateConfig configuration;
3533

@@ -45,9 +43,7 @@ class DegreeCentralityMutateStep implements MutateOrWriteStep<DegreeCentralityRe
4543
public NodePropertiesWritten execute(
4644
Graph graph,
4745
GraphStore graphStore,
48-
ResultStore resultStore,
49-
DegreeCentralityResult result,
50-
JobId jobId
46+
DegreeCentralityResult result
5147
) {
5248
return mutateNodeProperty.mutateNodeProperties(
5349
graph,

‎applications/algorithms/centrality/src/main/java/org/neo4j/gds/applications/algorithms/centrality/DegreeCentralityWriteStep.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,15 +23,15 @@
2323
import org.neo4j.gds.api.Graph;
2424
import org.neo4j.gds.api.GraphStore;
2525
import org.neo4j.gds.api.ResultStore;
26-
import org.neo4j.gds.applications.algorithms.machinery.MutateOrWriteStep;
26+
import org.neo4j.gds.applications.algorithms.machinery.WriteStep;
2727
import org.neo4j.gds.applications.algorithms.machinery.WriteToDatabase;
2828
import org.neo4j.gds.applications.algorithms.metadata.NodePropertiesWritten;
2929
import org.neo4j.gds.core.utils.progress.JobId;
3030
import org.neo4j.gds.degree.DegreeCentralityWriteConfig;
3131

3232
import static org.neo4j.gds.applications.algorithms.metadata.Algorithm.DegreeCentrality;
3333

34-
class DegreeCentralityWriteStep implements MutateOrWriteStep<CentralityAlgorithmResult, NodePropertiesWritten> {
34+
class DegreeCentralityWriteStep implements WriteStep<CentralityAlgorithmResult, NodePropertiesWritten> {
3535
private final WriteToDatabase writeToDatabase;
3636
private final DegreeCentralityWriteConfig configuration;
3737

0 commit comments

Comments
 (0)