File tree Expand file tree Collapse file tree 4 files changed +38
-655
lines changed
main/java/org/neo4j/gds/similarity/filteredknn
test/java/org/neo4j/gds/similarity/filteredknn Expand file tree Collapse file tree 4 files changed +38
-655
lines changed Original file line number Diff line number Diff line change 2525import org .neo4j .gds .similarity .knn .Knn ;
2626import org .neo4j .gds .similarity .knn .KnnContext ;
2727
28- <<<<<<< HEAD
29- =======
30- import java .util .List ;
31-
3228/**
3329 * Filtered KNN is the same as ordinary KNN, _but_ we allow users to regulate final output in two ways.
3430 *
@@ -74,10 +70,10 @@ public FilteredKnnResult compute() {
7470 Knn .Result result = delegate .compute ();
7571
7672 return ImmutableFilteredKnnResult .of (
77- targetNodeFiltering ,
7873 result .ranIterations (),
7974 result .didConverge (),
8075 result .nodePairsConsidered (),
76+ targetNodeFiltering ,
8177 sourceNodeFilter
8278 );
8379 }
Original file line number Diff line number Diff line change 2222import org .neo4j .gds .annotation .ValueClass ;
2323import org .neo4j .gds .similarity .SimilarityResult ;
2424
25- import java .util .List ;
2625import java .util .stream .Stream ;
2726
2827@ ValueClass
2928public abstract class FilteredKnnResult {
30- abstract TargetNodeFiltering neighbourConsumers ();
31-
3229 public abstract int ranIterations ();
3330
3431 public abstract boolean didConverge ();
3532
3633 public abstract long nodePairsConsidered ();
3734
38- public abstract List <Long > sourceNodes ();
39-
4035 public Stream <SimilarityResult > similarityResultStream () {
4136 TargetNodeFiltering neighbourConsumers = neighbourConsumers ();
42- List < Long > sourceNodes = sourceNodes ();
37+ NodeFilter sourceNodeFilter = sourceNodeFilter ();
4338
44- return neighbourConsumers .asSimilarityResultStream (sourceNodes :: contains );
39+ return neighbourConsumers .asSimilarityResultStream (sourceNodeFilter );
4540 }
41+
42+ // ***
43+ // Below is for internal use only
44+ // ***
45+ abstract TargetNodeFiltering neighbourConsumers ();
46+ abstract NodeFilter sourceNodeFilter ();
4647}
Load Diff This file was deleted.
You can’t perform that action at this time.
0 commit comments