Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Providing provenance fork event for the created segments generated by SplitJson.

This commit is contained in:
Aldrin Piri 2015-02-28 16:04:43 -05:00
parent 6a89745ec8
commit 57aa5dd63f
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
nifi/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SplitJson.java
View File

@ -138,6 +138,8 @@ public class SplitJson extends AbstractJsonPathProcessor {
segments.add(split); segments.add(split);
} }
processSession.getProvenanceReporter().fork(original, segments);
processSession.transfer(segments, REL_SPLIT); processSession.transfer(segments, REL_SPLIT);
processSession.transfer(original, REL_ORIGINAL); processSession.transfer(original, REL_ORIGINAL);
logger.info("Split {} into {} FlowFiles", new Object[]{original, segments.size()}); logger.info("Split {} into {} FlowFiles", new Object[]{original, segments.size()});