I am sending into the MergeContent processor, payloads that each belong in a certain group of files in some data I'm working with. Each payload has an attribute called "groupId" which is an identification number for a particular group of files. This is the attribute I'm using to bin each incoming flowfile, and have set the Correlation Attribute Name to groupId.
The problem I'm dealing with right now is that each groupId has a varying number of files associated with it. As such, I'm not sure how in NiFi to detect when the MergeContent processor has received all files for a particular groupId, and once done, release the bin. Any help with this problem is appreciated, thanks!
