NIFI-3216 added ability to wait for N signals. It supports waiting for N fragments split by SplitXXXX processors. However, since Notify processor has to increase count one by one by calling expensive replace cache operation over network, it doesn't provide a practical performance when user configured a flow looks like below as N glow:
This JIRA improves Notify processor by:
- Add "Signal Buffer Count" to specify max number of flow files that can be buffered and update cache at once
- Add "Signal Counter Delta" to specify delta grater than 1, EL supported
"Signal Buffer Count" would be useful in a flow like this:
Buffer incoming M flow files and perform cache replace operation once.
So does "Signal Counter Delta":
Specify 'M' via Attribute Expression Language.