Skip to content

Commit ade3262

Browse files
committed
Add draft for bug fix for list-fix-paths #686
1 parent 1b36009 commit ade3262

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

metafix/src/main/java/org/metafacture/metafix/FindFixPaths.java

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -25,8 +25,11 @@
2525
import org.metafacture.framework.annotations.In;
2626
import org.metafacture.framework.annotations.Out;
2727
import org.metafacture.framework.helpers.DefaultStreamPipe;
28+
import org.metafacture.mangling.DuplicateObjectFilter;
2829
import org.metafacture.mangling.StreamFlattener;
2930
import org.metafacture.triples.StreamToTriples;
31+
import org.metafacture.triples.TripleSort;
32+
import org.metafacture.triples.AbstractTripleSort.Compare;
3033
import org.metafacture.triples.TripleFilter;
3134

3235
import java.io.IOException;
@@ -67,11 +70,15 @@ public FindFixPaths(final String objectPattern) {
6770
protected void onSetReceiver() {
6871
final TripleFilter tripleFilter = new TripleFilter();
6972
tripleFilter.setObjectPattern(objectPattern);
73+
TripleSort tripleSort = new TripleSort();
74+
tripleSort.setBy(Compare.PREDICATE);
7075
fix
7176
.setReceiver(new StreamFlattener())
7277
.setReceiver(new StreamToTriples())
7378
.setReceiver(tripleFilter)
79+
.setReveiver(tripleSort)
7480
.setReceiver(new ObjectTemplate<>("${p}\t|\t${o}"))
81+
.setReceiver(new DuplicateObjectFilter<>())
7582
.setReceiver(getReceiver());
7683
}
7784

0 commit comments

Comments
 (0)