Merge #687 from branch metafacture/686-findFixValuesUniq

Enforce unique result in  list-fix-paths

Author: dr0i

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

@@ -47,19 +47,28 @@ public FindFixPathsTest() {
     public void testShouldFindPaths() {
         verify(
                 "a\t|\tAn ETL test",
+                "a\t|\tAnother ETL test",
                 "c.2\t|\tETL what?");
     }
 
     private void processRecord() {
         finder.setReceiver(receiver);
-        finder.startRecord("");
+        finder.startRecord("1");
         finder.literal("a", "An ETL test");
         finder.literal("b", "");
         finder.literal("b", "Dummi");
         finder.literal("b", "Dog");
         finder.literal("c", "");
         finder.literal("c", "ETL what?");
         finder.endRecord();
+        finder.startRecord("2");
+        finder.literal("a", "Another ETL test");
+        finder.literal("b", "");
+        finder.literal("b", "Dummi");
+        finder.literal("b", "Dog");
+        finder.literal("c", "");
+        finder.literal("c", "ETL what?");
+        finder.endRecord();
         finder.closeStream();
     }