Skip to content

Commit

Permalink
mnor
Browse files Browse the repository at this point in the history
  • Loading branch information
IoannisPanagiotas committed Nov 21, 2024
1 parent 6c72cfe commit 9fc6d5f
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -468,7 +468,7 @@ public Stream<MemoryEstimateResult> deltaSteppingStatsEstimate(

@Override
public Stream<PathFindingStreamResult> deltaSteppingStream(String graphName, Map<String, Object> configuration) {
var resultBuilder = new PathFindingResultBuilderForStreamMode<AllShortestPathsDeltaStreamConfig>(
var resultBuilder = new PathFindingResultBuilderForStreamMode(
closeableResourceRegistry,
nodeLookup,
procedureReturnColumns.contains("path")
Expand Down Expand Up @@ -562,7 +562,7 @@ public Stream<KSpanningTreeWriteResult> kSpanningTreeWrite(String graphName, Map

@Override
public Stream<PathFindingStreamResult> longestPathStream(String graphName, Map<String, Object> configuration) {
var resultBuilder = new PathFindingResultBuilderForStreamMode<DagLongestPathStreamConfig>(
var resultBuilder = new PathFindingResultBuilderForStreamMode(
closeableResourceRegistry,
nodeLookup,
procedureReturnColumns.contains("path")
Expand Down Expand Up @@ -646,7 +646,7 @@ public Stream<PathFindingStreamResult> singlePairShortestPathAStarStream(
String graphName,
Map<String, Object> configuration
) {
var resultBuilder = new PathFindingResultBuilderForStreamMode<ShortestPathAStarStreamConfig>(
var resultBuilder = new PathFindingResultBuilderForStreamMode(
closeableResourceRegistry,
nodeLookup,
procedureReturnColumns.contains("path")
Expand Down Expand Up @@ -710,7 +710,7 @@ public Stream<PathFindingStreamResult> singlePairShortestPathDijkstraStream(
String graphName,
Map<String, Object> configuration
) {
var resultBuilder = new PathFindingResultBuilderForStreamMode<ShortestPathDijkstraStreamConfig>(
var resultBuilder = new PathFindingResultBuilderForStreamMode(
closeableResourceRegistry,
nodeLookup,
procedureReturnColumns.contains("path")
Expand Down Expand Up @@ -774,7 +774,7 @@ public Stream<PathFindingStreamResult> singlePairShortestPathYensStream(
String graphName,
Map<String, Object> configuration
) {
var resultBuilder = new PathFindingResultBuilderForStreamMode<ShortestPathYensStreamConfig>(
var resultBuilder = new PathFindingResultBuilderForStreamMode(
closeableResourceRegistry,
nodeLookup,
procedureReturnColumns.contains("path")
Expand Down Expand Up @@ -838,7 +838,7 @@ public Stream<PathFindingStreamResult> singleSourceShortestPathDijkstraStream(
String graphName,
Map<String, Object> configuration
) {
var resultBuilder = new PathFindingResultBuilderForStreamMode<AllShortestPathsDijkstraStreamConfig>(
var resultBuilder = new PathFindingResultBuilderForStreamMode(
closeableResourceRegistry,
nodeLookup,
procedureReturnColumns.contains("path")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@

import static org.neo4j.gds.utils.StringFormatting.formatWithLocale;

public class PathFindingResultBuilderForStreamMode<CONFIGURATION> implements StreamResultBuilder<PathFindingResult, PathFindingStreamResult> {
public class PathFindingResultBuilderForStreamMode implements StreamResultBuilder<PathFindingResult, PathFindingStreamResult> {
private final CloseableResourceRegistry closeableResourceRegistry;
private final NodeLookup nodeLookup;
private final boolean pathRequested;
Expand Down

0 comments on commit 9fc6d5f

Please sign in to comment.