Providing provenance fork event for the created segments generated by SplitJson.
Project: http://git-wip-us.apache.org/repos/asf/incubator-nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-nifi/commit/57aa5dd6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-nifi/tree/57aa5dd6 Diff: http://git-wip-us.apache.org/repos/asf/incubator-nifi/diff/57aa5dd6 Branch: refs/heads/develop Commit: 57aa5dd63f25c281ba95869bfbfab465465b29f8 Parents: 6a89745 Author: Aldrin Piri <aldrinp...@gmail.com> Authored: Sat Feb 28 16:04:43 2015 -0500 Committer: Aldrin Piri <aldrinp...@gmail.com> Committed: Sat Feb 28 16:04:43 2015 -0500 ---------------------------------------------------------------------- .../main/java/org/apache/nifi/processors/standard/SplitJson.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/57aa5dd6/nifi/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SplitJson.java ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SplitJson.java b/nifi/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SplitJson.java index 8df2de0..fe2216a 100644 --- a/nifi/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SplitJson.java +++ b/nifi/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SplitJson.java @@ -138,6 +138,8 @@ public class SplitJson extends AbstractJsonPathProcessor { segments.add(split); } + processSession.getProvenanceReporter().fork(original, segments); + processSession.transfer(segments, REL_SPLIT); processSession.transfer(original, REL_ORIGINAL); logger.info("Split {} into {} FlowFiles", new Object[]{original, segments.size()});
