Github user ijokarumawak commented on a diff in the pull request:
https://github.com/apache/nifi/pull/1394#discussion_r101223043
--- Diff:
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SplitText.java
---
@@ -326,6 +329,27 @@ public void process(InputStream in) throws IOException
{
return splitFlowFiles;
}
+ /**
+ * Will merge the two files. This operation has different semantics
then
+ * sessioin.merge. Also, it always expects 2 and no more then 2 flow
files,
+ * so vararg signature primarily for simplification.
+ */
+ private FlowFile merge(ProcessSession session, FlowFile... flowFiles) {
+ FlowFile mergedFlowFile = session.create();
--- End diff --
@olegz Excuse me if I wasn't clear enough, but I was mentioning about the
relationship between original incoming FlowFile and outgoing FlowFiles those
are derived from the original FlowFile.
The 2nd one in the var arg is a FlowFile which is derived from the original
and it has provenance to the original file, but if we create another FlowFile
here, the lineage gets lost.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
