nifi-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From joew...@apache.org
Subject [39/50] [abbrv] incubator-nifi git commit: Providing provenance fork event for the created segments generated by SplitJson.
Date Mon, 02 Mar 2015 04:04:18 GMT
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 <aldrinpiri@gmail.com>
Authored: Sat Feb 28 16:04:43 2015 -0500
Committer: Aldrin Piri <aldrinpiri@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()});


Mime
View raw message