Hi Brian ,
Thank a lot for your advice and your help :)
Steve
Le ven. 23 août 2019 à 23:36, Matt Burgess a écrit :
> Steve,
>
> In a flow-based system like NiFi it can be difficult to tell when
> there are "no more events with the same key". However if you have a
> notion of the max amount of t
Steve,
In a flow-based system like NiFi it can be difficult to tell when
there are "no more events with the same key". However if you have a
notion of the max amount of time where events would appear, you might
be able to use MergeRecord or MergeContent with a Correlation
Attribute Name of "eventU
Hi Brian ,
thank you for your reply.
To be precise I studied the possibility to open a window on an attribute
value and close it after an user-defined time and if there are no more
events with the same key.
In flink side lot operator send Event with SUCCESS OR FAIL . operator is
running in para
I think AttributeRollingWindow was made to aggregate a numeric
attribute. So for example, if all flows files had an attribute called
"amount" that was an integer, then you could say Value to Track =
${amount} and it would aggregate those values over window.
In your case the attribute you have is n
Hi Guys ,
I apologize in advance if my question seems trivial but I am new on Nifi.
I'm studying Nifi for an integration with Flink that I'm used to.
Since flink I send events using Site-to-Site to Nifi.
the Flowfile have attribute "eventUuid":"
97f82c90-0782-4aab-8850-56ee60b0b73d"
I would like
