If you know one of the supported scripting languages, you can probably do
some of that with ExecuteScript. For example, if you wanted to drop every
other flowfile in a block of 100, it'd be like this:
def flowfiles = session.get(100) // Get up to 100
int index = 1
flowfiles?.each { flowFile ->
if
How is it going to work with e.g. 20GB of events in the queue? I'd be
careful, as requirements blow up into a full db with indexes, search, and a
UI on top. If one wanted to filter events, wouldn't a standard processor do
the job better?
Andrew
On Tue, Mar 27, 2018, 12:11 AM Joe Witt
Scott
Yep definitely something we've talked about [1]. We've not pursued it
directly as of yet since it is indeed a queue and we're just letting
you peak into it. We dont have facilities built in to really alter
the queue in a particular position. Also, the complexity comes in
when folks want
