performance improvement for StandardBlocker

olehmberg · Jun 23, 2017 · 46dc45a · 46dc45a
1 parent 283ddbf
commit 46dc45a
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/java/de/uni_mannheim/informatik/dws/winter/matching/blockers/StandardBlocker.java b/src/main/java/de/uni_mannheim/informatik/dws/winter/matching/blockers/StandardBlocker.java
@@ -217,7 +217,7 @@ public Pair<BlockedType, Processable<Correspondence<CorrespondenceType, Matchabl
 				for(int j = i+1; j < list.size(); j++) {
 					Pair<BlockedType, Processable<Correspondence<CorrespondenceType, Matchable>>> p2 = list.get(j);
 
-					Processable<Correspondence<CorrespondenceType, Matchable>> causes = new ProcessableCollection<>(p1.getSecond()).append(p2.getSecond()).distinct();
+					Processable<Correspondence<CorrespondenceType, Matchable>> causes = new ProcessableCollection<>(p1.getSecond()).append(p2.getSecond());
 
 					int[] pairIds = new int[] { p1.getFirst().getDataSourceIdentifier(), p2.getFirst().getDataSourceIdentifier() };
 					Arrays.sort(pairIds);
@@ -229,7 +229,7 @@ public Pair<BlockedType, Processable<Correspondence<CorrespondenceType, Matchabl
 						Arrays.sort(causeIds);
 
 						return Arrays.equals(pairIds, causeIds);
-					});
+					}).distinct();
 
 					collector.next(new Correspondence<>(p1.getFirst(), p2.getFirst(), 1.0, causes));
 				}