Enforce unique result #686

Author: TobiasNx

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

@@ -25,9 +25,12 @@
 import org.metafacture.framework.annotations.In;
 import org.metafacture.framework.annotations.Out;
 import org.metafacture.framework.helpers.DefaultStreamPipe;
+import org.metafacture.mangling.DuplicateObjectFilter;
 import org.metafacture.mangling.StreamFlattener;
+import org.metafacture.triples.AbstractTripleSort.Compare;
 import org.metafacture.triples.StreamToTriples;
 import org.metafacture.triples.TripleFilter;
+import org.metafacture.triples.TripleSort;
 
 import java.io.IOException;
 
@@ -37,7 +40,7 @@
  *
  * @author Tobias Bülte
  */
-@Description("Finds all paths that have values that match the given pattern. Allows for regex. These paths can be used in a Fix to address fields.")
+@Description("Finds all paths that have values that match the given pattern. Allows for regex. These paths can be used in a Fix to address fields.") // checkstyle-disable-line ClassDataAbstractionCoupling
 @In(StreamReceiver.class)
 @Out(String.class)
 @FluxCommand("find-fix-paths")
@@ -67,11 +70,15 @@ public FindFixPaths(final String objectPattern) {
     protected void onSetReceiver() {
         final TripleFilter tripleFilter = new TripleFilter();
         tripleFilter.setObjectPattern(objectPattern);
+        final TripleSort tripleSort = new TripleSort();
+        tripleSort.setBy(Compare.PREDICATE);
         fix
                 .setReceiver(new StreamFlattener())
                 .setReceiver(new StreamToTriples())
                 .setReceiver(tripleFilter)
+                .setReceiver(tripleSort)
                 .setReceiver(new ObjectTemplate<>("${p}\t|\t${o}"))
+                .setReceiver(new DuplicateObjectFilter<>())
                 .setReceiver(getReceiver());
     }
 

metafix/src/test/java/org/metafacture/metafix/FindFixPathsTest.java

@@ -46,7 +46,7 @@ public FindFixPathsTest() {
     @Test
     public void testShouldFindPaths() {
         verify(
-                "a\t|\tAn ETL test",
+                "a.1\t|\tAn ETL test",
                 "c.2\t|\tETL what?");
     }
 
@@ -59,6 +59,7 @@ private void processRecord() {
         finder.literal("b", "Dog");
         finder.literal("c", "");
         finder.literal("c", "ETL what?");
+        finder.literal("a", "An ETL test");
         finder.endRecord();
         finder.closeStream();
     }
@@ -72,7 +73,6 @@ private void verify(final String... result) throws MockitoAssertionError {
             }
             ordered.verify(receiver, Mockito.times(2)).closeStream();
             ordered.verifyNoMoreInteractions();
-            Mockito.verifyNoMoreInteractions(receiver);
         }
         catch (final MockitoAssertionError e) {
             System.out.println(Mockito.mockingDetails(receiver).printInvocations());