Just some considerations from my side as for the latency. I think the
first step should be defining what does "latency" for a CEP library really
The first thing that comes to my mind is the time period between the
arrival of an event that should trigger a match (ending pattern) and actual
time when the match is emitted(for that case a select function is a good
place I think).
I think Kostas was also referring to similar kind of issue.
Hope it will be helpful.
Z pozdrowieniami! / Cheers!
Skype: dawid_wys | Twitter: @OneMoreCoder
2017-05-19 10:59 GMT+02:00 Sonex <alfredjens...@gmail.com>:
> Hello Kostas,
> thanks for your response. Regarding throughput, it makes sense.
> But there is still one question remaining. How can I measure the latency of
> my FlinkCEP application ???
> Maybe you answered it, but I didn`t quite get that. As far as your number 2
> question about measuring latency, the answer is yes, the first element in
> the matching pattern will wait inevitably longer than the last one
> Thank you for your time!!!
> View this message in context: http://apache-flink-user-
> Sent from the Apache Flink User Mailing List archive. mailing list archive
> at Nabble.com.