File tree Expand file tree Collapse file tree 1 file changed +5
-3
lines changed
metafacture-strings/src/main/java/org/metafacture/strings Expand file tree Collapse file tree 1 file changed +5
-3
lines changed Original file line number Diff line number Diff line change 23
23
import org .metafacture .framework .helpers .DefaultObjectPipe ;
24
24
25
25
/**
26
- * Joins strings and emits them as records when a line matches the pattern.
26
+ * Collects trings and emits them as records when a line matches the pattern.
27
+ * Appends to every incoming line a line feed so that the original structure is
28
+ * preserved.
27
29
*
28
30
* @author Pascal Christoph (dr0i).
29
31
*
30
32
*/
31
- @ Description ("Joins strings and emits them as records when a line matches the pattern." )
33
+ @ Description ("Collects strings and emits them as records when a line matches the pattern." )
32
34
@ In (String .class )
33
35
@ Out (String .class )
34
36
@ FluxCommand ("lines-to-records" )
@@ -50,7 +52,7 @@ public void process(final String line) {
50
52
getReceiver ().process (record .toString ());
51
53
record = new StringBuilder (SB_CAPACITY );
52
54
} else
53
- record .append (line );
55
+ record .append (line + " \n " );
54
56
}
55
57
56
58
}
You can’t perform that action at this time.
0 commit comments