Nicolas, I don't believe there is support for this in MergeContent. It does support a similar pattern for segmented data such that it knows how to recombine it. It handles out of order alignment and understanding start/end/indexes. However, it requires specific metadata be made available. You'd want to build/have something that support your particular case.
Thanks Joe On Wed, Nov 30, 2016 at 4:07 AM, Provenzano Nicolas <[email protected]> wrote: > Hi all, > > > > Yet another question… > > > > I defined a flow to process session information coming from CSV files. > > > > Each record contains a session ID, a session state and some session > counters. > > > > The merge content processor allows merging flowfiles according to an > attribute (the correlation attribute name) so I was able to merge flowfiles > according to the session ID. > > > > However, I would like to trigger the merging only when the session state > reaches a specific value (for example, ended). > > > > Please note that session info can be distributed over several input flows > but always end with state = ended. > > > > So for example, a first CSV file contains : > > > > 100, started, 1, 2 > > > > A second CSV file contains > > > > 100, inProgress, 2, 4 > > > > And a third CSV file contains > > > > 100, ended, 4,6 > > > > The merge content processor should then produce the following flowfile : > > > > 100, started, 1, 2 > > 100, inProgress, 2, 4 > > 100, ended, 4,6 > > > > Meaning that the two first records should be kept as long as the “ended” one > is not received. > > > > Is there anyway of doing it directly with this processor or with any others > ? > > > > Thanks > > > > Nicolas
