I have tried a ControlRate but it doesn't work because it seems to stop processing once the threshold of 1 is reached, even though I set a grouping property (I know there are two different values for my group in my queue). Any clue?
On Thu, May 26, 2016 at 2:30 PM Stéphane Maarek <[email protected]> wrote: > Hi, > > I need to output some data streaming from multiple devices directly into a > map (mapboxjs). > > Basically, every 1 second, I want to only write the last data point for > each device to a json file. My problem resides in "how to pick the latest > data point by device" > > My incoming flow file has three attributes: device_id, lat, lon. > at some point they may queue up like this: > > 1, (-37,20) > 1, (-37.1,20.1) > 2, (-40,30) > 2, (-40.1, 29.9) > > At the end, I wish to only have the latest point for each device ID > 1, (-37.1,20.1) > 2, (-40.1, 29.9) > > How can I design a processor for this? > > Thanks! > Stephane >
