Hello once again,
If you want to use CEP library you can e.g. key by device, then apply
pattern:
Pattern.begin("connect").where(...)
.followedBy("established").where(new IterativeCondition() {
@Override
public boolean filter(
Event value, Context ctx) throws Exception {
Hi Florin,
I concur with Dian. If you have any other questions, please do not
hesitate to ask.
Best,
Dawid
On 13/12/2018 03:37, fudian.fd wrote:
> Hi Florin,
>
> Are you using processing time or event time? The JIRA FLINK-7384
> allows to emit timed-out patterns without having to wait for the
Hello, Dian!
Thank you very much for your explanations. In my case, CEP patterns are
based on the event time. Also, as you said I have many devices and also
many ports on that devices. Therefore, I'm using keyed streams.
So I would like to know which device was disconnected on which port.
Is
Hi Florin,
I think Dawid might help you. I am pulling him into the discussion.
Best,
Andrey
> On 12 Dec 2018, at 16:24, Spico Florin wrote:
>
> Hello!
> I'm using the same questions as in this stackoverflow post
>
Hello!
I'm using the same questions as in this stackoverflow post
https://stackoverflow.com/questions/50356981/apache-flink-cep-how-to-detect-if-event-did-not-occur-within-x-seconds?rq=1,
due to fact that I need the same functionality.
My use case is to detect when an device is disconnected from
