Skip to content

Commit 1106cd4

Browse files
IoannisPanagiotasIoannisPanagiotas
committed
Remove configuration from builder in Stream
1 parent e9240ec commit 1106cd4

File tree

56 files changed

+207
-196
lines changed

Some content is hidden

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

56 files changed

+207
-196
lines changed

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

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -41,8 +41,8 @@
4141

4242
import static org.neo4j.gds.applications.algorithms.metadata.Algorithm.ArticleRank;
4343
import static org.neo4j.gds.applications.algorithms.metadata.Algorithm.ArticulationPoints;
44-
import static org.neo4j.gds.applications.algorithms.metadata.Algorithm.Bridges;
4544
import static org.neo4j.gds.applications.algorithms.metadata.Algorithm.BetweennessCentrality;
45+
import static org.neo4j.gds.applications.algorithms.metadata.Algorithm.Bridges;
4646
import static org.neo4j.gds.applications.algorithms.metadata.Algorithm.CELF;
4747
import static org.neo4j.gds.applications.algorithms.metadata.Algorithm.ClosenessCentrality;
4848
import static org.neo4j.gds.applications.algorithms.metadata.Algorithm.DegreeCentrality;
@@ -68,7 +68,7 @@ public class CentralityAlgorithmsStreamModeBusinessFacade {
6868
public <RESULT> Stream<RESULT> articleRank(
6969
GraphName graphName,
7070
PageRankStreamConfig configuration,
71-
StreamResultBuilder<PageRankStreamConfig, PageRankResult, RESULT> streamResultBuilder
71+
StreamResultBuilder<PageRankResult, RESULT> streamResultBuilder
7272
) {
7373
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInStreamMode(
7474
graphName,
@@ -83,7 +83,7 @@ public <RESULT> Stream<RESULT> articleRank(
8383
public <RESULT> Stream<RESULT> betweennessCentrality(
8484
GraphName graphName,
8585
BetweennessCentralityStreamConfig configuration,
86-
StreamResultBuilder<BetweennessCentralityStreamConfig, CentralityAlgorithmResult, RESULT> streamResultBuilder
86+
StreamResultBuilder<CentralityAlgorithmResult, RESULT> streamResultBuilder
8787
) {
8888
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInStreamMode(
8989
graphName,
@@ -97,7 +97,7 @@ public <RESULT> Stream<RESULT> betweennessCentrality(
9797
public <RESULT> Stream<RESULT> articulationPoints(
9898
GraphName graphName,
9999
ArticulationPointsStreamConfig configuration,
100-
StreamResultBuilder<ArticulationPointsStreamConfig, BitSet, RESULT> streamResultBuilder
100+
StreamResultBuilder<BitSet, RESULT> streamResultBuilder
101101
) {
102102
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInStreamMode(
103103
graphName,
@@ -111,7 +111,7 @@ public <RESULT> Stream<RESULT> articulationPoints(
111111
public <RESULT> Stream<RESULT> bridges(
112112
GraphName graphName,
113113
BridgesStreamConfig configuration,
114-
StreamResultBuilder<BridgesStreamConfig, BridgeResult, RESULT> streamResultBuilder
114+
StreamResultBuilder<BridgeResult, RESULT> streamResultBuilder
115115
) {
116116
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInStreamMode(
117117
graphName,
@@ -126,7 +126,7 @@ public <RESULT> Stream<RESULT> bridges(
126126
public <RESULT> Stream<RESULT> celf(
127127
GraphName graphName,
128128
InfluenceMaximizationStreamConfig configuration,
129-
StreamResultBuilder<InfluenceMaximizationStreamConfig, CELFResult, RESULT> streamResultBuilder
129+
StreamResultBuilder<CELFResult, RESULT> streamResultBuilder
130130
) {
131131
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInStreamMode(
132132
graphName,
@@ -141,7 +141,7 @@ public <RESULT> Stream<RESULT> celf(
141141
public <RESULT> Stream<RESULT> closenessCentrality(
142142
GraphName graphName,
143143
ClosenessCentralityStreamConfig configuration,
144-
StreamResultBuilder<ClosenessCentralityStreamConfig, CentralityAlgorithmResult, RESULT> streamResultBuilder
144+
StreamResultBuilder<CentralityAlgorithmResult, RESULT> streamResultBuilder
145145
) {
146146
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInStreamMode(
147147
graphName,
@@ -156,7 +156,7 @@ public <RESULT> Stream<RESULT> closenessCentrality(
156156
public <RESULT> Stream<RESULT> degreeCentrality(
157157
GraphName graphName,
158158
DegreeCentralityStreamConfig configuration,
159-
StreamResultBuilder<DegreeCentralityStreamConfig, CentralityAlgorithmResult, RESULT> streamResultBuilder
159+
StreamResultBuilder<CentralityAlgorithmResult, RESULT> streamResultBuilder
160160
) {
161161
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInStreamMode(
162162
graphName,
@@ -171,7 +171,7 @@ public <RESULT> Stream<RESULT> degreeCentrality(
171171
public <RESULT> Stream<RESULT> eigenvector(
172172
GraphName graphName,
173173
PageRankStreamConfig configuration,
174-
StreamResultBuilder<PageRankStreamConfig, PageRankResult, RESULT> streamResultBuilder
174+
StreamResultBuilder<PageRankResult, RESULT> streamResultBuilder
175175
) {
176176
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInStreamMode(
177177
graphName,
@@ -186,7 +186,7 @@ public <RESULT> Stream<RESULT> eigenvector(
186186
public <RESULT> Stream<RESULT> harmonicCentrality(
187187
GraphName graphName,
188188
HarmonicCentralityStreamConfig configuration,
189-
StreamResultBuilder<HarmonicCentralityStreamConfig, HarmonicResult, RESULT> streamResultBuilder
189+
StreamResultBuilder<HarmonicResult, RESULT> streamResultBuilder
190190
) {
191191
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInStreamMode(
192192
graphName,
@@ -201,7 +201,7 @@ public <RESULT> Stream<RESULT> harmonicCentrality(
201201
public <RESULT> Stream<RESULT> pageRank(
202202
GraphName graphName,
203203
PageRankStreamConfig configuration,
204-
StreamResultBuilder<PageRankStreamConfig, PageRankResult, RESULT> streamResultBuilder
204+
StreamResultBuilder<PageRankResult, RESULT> streamResultBuilder
205205
) {
206206
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInStreamMode(
207207
graphName,

‎applications/algorithms/community/src/main/java/org/neo4j/gds/applications/algorithms/community/CommunityAlgorithmsStreamModeBusinessFacade.java

Lines changed: 15 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -89,7 +89,7 @@ public class CommunityAlgorithmsStreamModeBusinessFacade {
8989
public <RESULT> Stream<RESULT> approximateMaximumKCut(
9090
GraphName graphName,
9191
ApproxMaxKCutStreamConfig configuration,
92-
StreamResultBuilder<ApproxMaxKCutStreamConfig, ApproxMaxKCutResult, RESULT> streamResultBuilder
92+
StreamResultBuilder<ApproxMaxKCutResult, RESULT> streamResultBuilder
9393
) {
9494
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInStreamMode(
9595
graphName,
@@ -104,7 +104,7 @@ public <RESULT> Stream<RESULT> approximateMaximumKCut(
104104
public <RESULT> Stream<RESULT> conductance(
105105
GraphName graphName,
106106
ConductanceStreamConfig configuration,
107-
StreamResultBuilder<ConductanceStreamConfig, ConductanceResult, RESULT> streamResultBuilder
107+
StreamResultBuilder<ConductanceResult, RESULT> streamResultBuilder
108108
) {
109109
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInStreamMode(
110110
graphName,
@@ -119,7 +119,7 @@ public <RESULT> Stream<RESULT> conductance(
119119
public <RESULT> Stream<RESULT> k1Coloring(
120120
GraphName graphName,
121121
K1ColoringStreamConfig configuration,
122-
StreamResultBuilder<K1ColoringStreamConfig, K1ColoringResult, RESULT> streamResultBuilder
122+
StreamResultBuilder<K1ColoringResult, RESULT> streamResultBuilder
123123
) {
124124
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInStreamMode(
125125
graphName,
@@ -134,7 +134,7 @@ public <RESULT> Stream<RESULT> k1Coloring(
134134
public <RESULT> Stream<RESULT> kCore(
135135
GraphName graphName,
136136
KCoreDecompositionStreamConfig configuration,
137-
StreamResultBuilder<KCoreDecompositionStreamConfig, KCoreDecompositionResult, RESULT> streamResultBuilder
137+
StreamResultBuilder<KCoreDecompositionResult, RESULT> streamResultBuilder
138138
) {
139139
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInStreamMode(
140140
graphName,
@@ -149,7 +149,7 @@ public <RESULT> Stream<RESULT> kCore(
149149
public <RESULT> Stream<RESULT> kMeans(
150150
GraphName graphName,
151151
KmeansStreamConfig configuration,
152-
StreamResultBuilder<KmeansStreamConfig, KmeansResult, RESULT> streamResultBuilder
152+
StreamResultBuilder<KmeansResult, RESULT> streamResultBuilder
153153
) {
154154
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInStreamMode(
155155
graphName,
@@ -164,7 +164,7 @@ public <RESULT> Stream<RESULT> kMeans(
164164
public <RESULT> Stream<RESULT> labelPropagation(
165165
GraphName graphName,
166166
LabelPropagationStreamConfig configuration,
167-
StreamResultBuilder<LabelPropagationStreamConfig, LabelPropagationResult, RESULT> streamResultBuilder
167+
StreamResultBuilder<LabelPropagationResult, RESULT> streamResultBuilder
168168
) {
169169
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInStreamMode(
170170
graphName,
@@ -179,7 +179,7 @@ public <RESULT> Stream<RESULT> labelPropagation(
179179
public <RESULT> Stream<RESULT> lcc(
180180
GraphName graphName,
181181
LocalClusteringCoefficientStreamConfig configuration,
182-
StreamResultBuilder<LocalClusteringCoefficientStreamConfig, LocalClusteringCoefficientResult, RESULT> streamResultBuilder
182+
StreamResultBuilder<LocalClusteringCoefficientResult, RESULT> streamResultBuilder
183183
) {
184184
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInStreamMode(
185185
graphName,
@@ -194,7 +194,7 @@ public <RESULT> Stream<RESULT> lcc(
194194
public <RESULT> Stream<RESULT> leiden(
195195
GraphName graphName,
196196
LeidenStreamConfig configuration,
197-
StreamResultBuilder<LeidenStreamConfig, LeidenResult, RESULT> streamResultBuilder
197+
StreamResultBuilder<LeidenResult, RESULT> streamResultBuilder
198198
) {
199199
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInStreamMode(
200200
graphName,
@@ -209,7 +209,7 @@ public <RESULT> Stream<RESULT> leiden(
209209
public <RESULT> Stream<RESULT> louvain(
210210
GraphName graphName,
211211
LouvainStreamConfig configuration,
212-
StreamResultBuilder<LouvainStreamConfig, LouvainResult, RESULT> streamResultBuilder
212+
StreamResultBuilder<LouvainResult, RESULT> streamResultBuilder
213213
) {
214214
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInStreamMode(
215215
graphName,
@@ -224,7 +224,7 @@ public <RESULT> Stream<RESULT> louvain(
224224
public <RESULT> Stream<RESULT> modularity(
225225
GraphName graphName,
226226
ModularityStreamConfig configuration,
227-
StreamResultBuilder<ModularityStreamConfig, ModularityResult, RESULT> streamResultBuilder
227+
StreamResultBuilder<ModularityResult, RESULT> streamResultBuilder
228228
) {
229229
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInStreamMode(
230230
graphName,
@@ -239,7 +239,7 @@ public <RESULT> Stream<RESULT> modularity(
239239
public <RESULT> Stream<RESULT> modularityOptimization(
240240
GraphName graphName,
241241
ModularityOptimizationStreamConfig configuration,
242-
StreamResultBuilder<ModularityOptimizationStreamConfig, ModularityOptimizationResult, RESULT> streamResultBuilder
242+
StreamResultBuilder<ModularityOptimizationResult, RESULT> streamResultBuilder
243243
) {
244244
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInStreamMode(
245245
graphName,
@@ -254,7 +254,7 @@ public <RESULT> Stream<RESULT> modularityOptimization(
254254
public <RESULT> Stream<RESULT> scc(
255255
GraphName graphName,
256256
SccStreamConfig configuration,
257-
StreamResultBuilder<SccStreamConfig, HugeLongArray, RESULT> streamResultBuilder
257+
StreamResultBuilder<HugeLongArray, RESULT> streamResultBuilder
258258
) {
259259
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInStreamMode(
260260
graphName,
@@ -269,7 +269,7 @@ public <RESULT> Stream<RESULT> scc(
269269
public <RESULT> Stream<RESULT> triangleCount(
270270
GraphName graphName,
271271
TriangleCountStreamConfig configuration,
272-
StreamResultBuilder<TriangleCountStreamConfig, TriangleCountResult, RESULT> streamResultBuilder
272+
StreamResultBuilder<TriangleCountResult, RESULT> streamResultBuilder
273273
) {
274274
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInStreamMode(
275275
graphName,
@@ -284,7 +284,7 @@ public <RESULT> Stream<RESULT> triangleCount(
284284
public <RESULT> Stream<RESULT> triangles(
285285
GraphName graphName,
286286
TriangleCountBaseConfig configuration,
287-
StreamResultBuilder<TriangleCountBaseConfig, Stream<TriangleStreamResult>, RESULT> streamResultBuilder
287+
StreamResultBuilder<Stream<TriangleStreamResult>, RESULT> streamResultBuilder
288288
) {
289289
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInStreamMode(
290290
graphName,
@@ -299,7 +299,7 @@ public <RESULT> Stream<RESULT> triangles(
299299
public <RESULT> Stream<RESULT> wcc(
300300
GraphName graphName,
301301
WccStreamConfig configuration,
302-
StreamResultBuilder<WccStreamConfig, DisjointSetStruct, RESULT> streamResultBuilder
302+
StreamResultBuilder<DisjointSetStruct, RESULT> streamResultBuilder
303303
) {
304304
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInStreamMode(
305305
graphName,

‎applications/algorithms/machine-learning/src/main/java/org/neo4j/gds/applications/algorithms/machinelearning/MachineLearningAlgorithmsStreamModeBusinessFacade.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@ public class MachineLearningAlgorithmsStreamModeBusinessFacade {
4848
public <RESULT> Stream<RESULT> kge(
4949
GraphName graphName,
5050
KGEPredictStreamConfig configuration,
51-
StreamResultBuilder<KGEPredictStreamConfig, KGEPredictResult, RESULT> resultBuilder
51+
StreamResultBuilder<KGEPredictResult, RESULT> resultBuilder
5252
) {
5353
return convenience.processRegularAlgorithmInStreamMode(
5454
graphName,

‎applications/algorithms/machinery/src/main/java/org/neo4j/gds/applications/algorithms/machinery/AlgorithmProcessingTemplate.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,7 @@ Stream<RESULT_TO_CALLER> processAlgorithmForStream(
7777
Algorithm algorithmMetadata,
7878
Supplier<MemoryEstimation> estimationFactory,
7979
AlgorithmComputation<RESULT_FROM_ALGORITHM> algorithmComputation,
80-
StreamResultBuilder<CONFIGURATION, RESULT_FROM_ALGORITHM, RESULT_TO_CALLER> resultBuilder
80+
StreamResultBuilder<RESULT_FROM_ALGORITHM, RESULT_TO_CALLER> resultBuilder
8181
);
8282

8383
<CONFIGURATION extends AlgoBaseConfig, RESULT_TO_CALLER, RESULT_FROM_ALGORITHM>

‎applications/algorithms/machinery/src/main/java/org/neo4j/gds/applications/algorithms/machinery/AlgorithmProcessingTemplateConvenience.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -117,7 +117,7 @@ public <CONFIGURATION extends AlgoBaseConfig, RESULT_TO_CALLER, RESULT_FROM_ALGO
117117
Algorithm algorithmMetadata,
118118
Supplier<MemoryEstimation> estimationFactory,
119119
AlgorithmComputation<RESULT_FROM_ALGORITHM> algorithmComputation,
120-
StreamResultBuilder<CONFIGURATION, RESULT_FROM_ALGORITHM, RESULT_TO_CALLER> resultBuilder,
120+
StreamResultBuilder<RESULT_FROM_ALGORITHM, RESULT_TO_CALLER> resultBuilder,
121121
Optional<Iterable<PostLoadValidationHook>> postGraphStoreLoadValidationHooks,
122122
Optional<String> relationshipWeightOverride
123123
) {
@@ -138,7 +138,7 @@ public <CONFIGURATION extends AlgoBaseConfig, RESULT_TO_CALLER, RESULT_FROM_ALGO
138138
Algorithm algorithmMetadata,
139139
Supplier<MemoryEstimation> estimationFactory,
140140
AlgorithmComputation<RESULT_FROM_ALGORITHM> algorithmComputation,
141-
StreamResultBuilder<CONFIGURATION, RESULT_FROM_ALGORITHM, RESULT_TO_CALLER> resultBuilder
141+
StreamResultBuilder<RESULT_FROM_ALGORITHM, RESULT_TO_CALLER> resultBuilder
142142
) {
143143
return processAlgorithmInStreamMode(
144144
graphName,

‎applications/algorithms/machinery/src/main/java/org/neo4j/gds/applications/algorithms/machinery/DefaultAlgorithmProcessingTemplate.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -123,7 +123,7 @@ public <CONFIGURATION extends AlgoBaseConfig, RESULT_TO_CALLER, RESULT_FROM_ALGO
123123
Algorithm algorithmMetadata,
124124
Supplier<MemoryEstimation> estimationFactory,
125125
AlgorithmComputation<RESULT_FROM_ALGORITHM> algorithmComputation,
126-
StreamResultBuilder<CONFIGURATION, RESULT_FROM_ALGORITHM, RESULT_TO_CALLER> resultBuilder
126+
StreamResultBuilder<RESULT_FROM_ALGORITHM, RESULT_TO_CALLER> resultBuilder
127127
) {
128128

129129
var timingsBuilder = new AlgorithmProcessingTimingsBuilder();
@@ -149,7 +149,6 @@ public <CONFIGURATION extends AlgoBaseConfig, RESULT_TO_CALLER, RESULT_FROM_ALGO
149149
return resultBuilder.build(
150150
graphResources.graph(),
151151
graphResources.graphStore(),
152-
configuration,
153152
result
154153
);
155154
}

‎applications/algorithms/machinery/src/main/java/org/neo4j/gds/applications/algorithms/machinery/StreamResultBuilder.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -26,17 +26,16 @@
2626
import java.util.stream.Stream;
2727

2828

29-
public interface StreamResultBuilder<CONFIGURATION, RESULT_FROM_ALGORITHM, RESULT_TO_CALLER> {
29+
public interface StreamResultBuilder<RESULT_FROM_ALGORITHM, RESULT_TO_CALLER> {
3030
/**
3131
* You implement this and use as much or as little of the gathered data as is appropriate.
3232
* Plus your own injected dependencies of course.
3333
*
34-
* @param result output from algorithm, empty when graph was empty
34+
* @param result output from algorithm, empty when graph was empty
3535
*/
3636
Stream<RESULT_TO_CALLER> build(
3737
Graph graph,
3838
GraphStore graphStore,
39-
CONFIGURATION configuration,
4039
Optional<RESULT_FROM_ALGORITHM> result
4140
);
4241
}

‎applications/algorithms/machinery/src/test/java/org/neo4j/gds/applications/algorithms/machinery/DefaultAlgorithmProcessingTemplateTest.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -87,12 +87,11 @@ void shouldProcessStreamAlgorithm() {
8787
var pathFindingResult = mock(ExampleResult.class);
8888
when(computation.compute(graph, graphStore)).thenReturn(pathFindingResult);
8989

90-
var resultBuilder = new StreamResultBuilder<ExampleConfiguration, ExampleResult, String>() {
90+
var resultBuilder = new StreamResultBuilder<ExampleResult, String>() {
9191
@Override
9292
public Stream<String> build(
9393
Graph graph,
9494
GraphStore graphStore,
95-
ExampleConfiguration configuration,
9695
Optional<ExampleResult> pathFindingResult
9796
) {
9897

‎applications/algorithms/miscellaneous-algorithms/src/main/java/org/neo4j/gds/applications/algorithms/miscellaneous/MiscellaneousApplicationsStreamModeBusinessFacade.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@ public class MiscellaneousApplicationsStreamModeBusinessFacade {
4747
public <RESULT> Stream<RESULT> scaleProperties(
4848
GraphName graphName,
4949
ScalePropertiesStreamConfig configuration,
50-
StreamResultBuilder<ScalePropertiesStreamConfig, ScalePropertiesResult, RESULT> resultBuilder
50+
StreamResultBuilder<ScalePropertiesResult, RESULT> resultBuilder
5151
) {
5252
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInStreamMode(
5353
graphName,

‎applications/algorithms/node-embeddings/src/main/java/org/neo4j/gds/applications/algorithms/embeddings/NodeEmbeddingAlgorithmsStreamModeBusinessFacade.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,7 @@ public class NodeEmbeddingAlgorithmsStreamModeBusinessFacade {
6161
public <RESULT> Stream<RESULT> fastRP(
6262
GraphName graphName,
6363
FastRPStreamConfig configuration,
64-
StreamResultBuilder<FastRPStreamConfig, FastRPResult, RESULT> resultBuilder
64+
StreamResultBuilder<FastRPResult, RESULT> resultBuilder
6565
) {
6666
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInStreamMode(
6767
graphName,
@@ -76,7 +76,7 @@ public <RESULT> Stream<RESULT> fastRP(
7676
public <RESULT> Stream<RESULT> graphSage(
7777
GraphName graphName,
7878
GraphSageStreamConfig configuration,
79-
StreamResultBuilder<GraphSageStreamConfig, GraphSageResult, RESULT> resultBuilder
79+
StreamResultBuilder<GraphSageResult, RESULT> resultBuilder
8080
) {
8181

8282
var graphSageProcessParameters = graphSageAlgorithmProcessing.graphSageValidationHook(configuration);
@@ -95,7 +95,7 @@ public <RESULT> Stream<RESULT> graphSage(
9595
public <RESULT> Stream<RESULT> hashGnn(
9696
GraphName graphName,
9797
HashGNNStreamConfig configuration,
98-
StreamResultBuilder<HashGNNStreamConfig, HashGNNResult, RESULT> resultBuilder
98+
StreamResultBuilder<HashGNNResult, RESULT> resultBuilder
9999
) {
100100
return algorithmProcessingTemplateConvenience.processRegularAlgorithmInStreamMode(
101101
graphName,
@@ -110,7 +110,7 @@ public <RESULT> Stream<RESULT> hashGnn(
110110
public <RESULT> Stream<RESULT> node2Vec(
111111
GraphName graphName,
112112
Node2VecStreamConfig configuration,
113-
StreamResultBuilder<Node2VecStreamConfig, Node2VecResult, RESULT> resultBuilder
113+
StreamResultBuilder<Node2VecResult, RESULT> resultBuilder
114114
) {
115115
return algorithmProcessingTemplateConvenience.processAlgorithmInStreamMode(
116116
graphName,

0 commit comments

Comments
 (0)