[
https://issues.apache.org/jira/browse/NIFI-3216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15812556#comment-15812556
]
Bryan Bende commented on NIFI-3216:
-----------------------------------
Final note... as part of this, it would also be nice to update the "split"
processors we have to add the total number of splits as an attribute to the
original flow file. For example, SplitJSON adds "fragment.count" to each split
flow file so that MergeContent can "defragment" them later, but it would be
nice to send the original JSON to a Wait processor with the "Signal Count" set
to ${fragment.count} and then send all the splits to a Notify processor, so
that the original JSON is released when all splits are done processing.
> Add ability to wait for N signals to Wait/Notify processors
> -----------------------------------------------------------
>
> Key: NIFI-3216
> URL: https://issues.apache.org/jira/browse/NIFI-3216
> Project: Apache NiFi
> Issue Type: Improvement
> Affects Versions: 1.2.0
> Reporter: Bryan Bende
>
> The recently added Wait and Notify processors allow a flow file to be held at
> the Wait processor until a signal is received in the Notify processor. It
> would be nice to be able to wait for N signals before releasing.
> One way this could be done is to have a property like "Signal Count" on the
> Wait processor, and then count the keys in the cache starting with some
> pattern, and release when the # of keys equals the signal count.
> This would require the ability to get all the keys from the cache, or at
> least get all keys matching a pattern:
> https://issues.apache.org/jira/browse/NIFI-3214
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
