Pierre Villard updated NIFI-2794:
    Attachment: image.png

The idea was to cover this kind of situation:


Example: I have a processor A going through a list of IDs and generating one 
FlowFile per ID. I have a processor B fetching data from one source for the 
given ID and the processor C does the same from another source. The processor D 
could use this method to get FlowFiles from both B and C for the same ID and 
join the data into one flow file.

I do realize now that this would be covered by the ongoing work with NIFI-2590, 
NIFI-1926, NIFI-2735.

There are more general patterns to cover here and this, without any doubt, can 
be achieved in a more elegant/general way.

> Expose a getOneFromEachConnection method in ProcessSession
> ----------------------------------------------------------
>                 Key: NIFI-2794
>                 URL: https://issues.apache.org/jira/browse/NIFI-2794
>             Project: Apache NiFi
>          Issue Type: Improvement
>          Components: Core Framework
>    Affects Versions: 1.0.0
>            Reporter: Pierre Villard
>            Assignee: Pierre Villard
>            Priority: Minor
>         Attachments: image.png
> In case a processor has multiple incoming connections, it could be 
> interesting to expose a method allowing users to get exactly one flow file 
> per incoming connection in a row.
> That could unlock opportunities such as performing join operations on 
> datasets.

This message was sent by Atlassian JIRA

Reply via email to