Hello
Actually I evaluate my WindowFunction with a trigger alert, having
something like below code (testing with 2 different windows), expecting 5K
elements per second arriving
SingleOutputStreamOperator windowedElem = element
.keyBy("id")
.timeWindow(Time.seconds(120))
// .window(EventTi
Hi antonio,
I think it worth a try to test the performance in your scenario, since job
performance can be affected by a number of factors(say your WindowFunction).
Best, Hequn
On Sat, Jul 21, 2018 at 2:59 AM, antonio saldivar
wrote:
> Hello
>
> I am building an app but for this UC I want to te
Hello
I am building an app but for this UC I want to test with session windows
and I am not sure if this will be expensive for the compute resources
because the gap will be 10 mins, 20 mins 60 mins because I want to trigger
an alert if the element reaches some thresholds within those periods of
ti
