Add support of separator as FLUX parameter for CsvDecoder

Assume that the first char of a String is meant for this case (reason: char
is needed for CSVReader).

Author: hagbeck

metafacture-csv/src/main/java/org/metafacture/csv/CsvDecoder.java

@@ -42,12 +42,20 @@
 public final class CsvDecoder extends DefaultObjectPipe<String, StreamReceiver>  {
 
     private static final char DEFAULT_SEP = ',';
-    private final char separator;
+    private char separator;
 
     private String[] header = new String[0];
     private int count;
     private boolean hasHeader;
 
+    /**
+     * @param separator to split lines
+     */
+    public CsvDecoder(final String separator) {
+        super();
+        this.separator = separator.charAt(0);
+    }
+
     /**
      * @param separator to split lines
      */
@@ -109,4 +117,5 @@ public void setHasHeader(final boolean hasHeader) {
         this.hasHeader = hasHeader;
     }
 
+    public void setSeparator(final String separator) { this.separator = separator.charAt(0); }
 }

metafacture-csv/src/test/java/org/metafacture/csv/CsvDecoderTest.java

@@ -74,4 +74,18 @@ public void testQuoted() {
         ordered.verify(receiver).endRecord();
     }
 
+    @Test
+    public void testTabSeparated() {
+
+        decoder.setSeparator("\t");
+
+        decoder.process("a\tb\tc");
+        final InOrder ordered = inOrder(receiver);
+        ordered.verify(receiver).startRecord("1");
+        ordered.verify(receiver).literal("h1", "a");
+        ordered.verify(receiver).literal("h2", "b");
+        ordered.verify(receiver).literal("h3", "c");
+        ordered.verify(receiver).endRecord();
+    }
+
 }