Support Questions
Find answers, ask questions, and share your expertise

Aggregate integer values of NiFi flowfile attributes for a specific time period

Aggregate integer values of NiFi flowfile attributes for a specific time period

Hi - is it possible to accumulate a tokenvalue I recieve from a stream for 10 minutes and add them all before sending it down for further processing ? 

 

I noticed the MergeContent and MergeRecord processors, but they are only doing the job of combining multiple flow files into one flowfile. Is there any other quick way of doing this as per my window definition - it can be 10 minutes, or 1 hour or 24 hours too. 

 

Don't have an account?