Hey Team,
I have Flink job with CEP with pattern t...
# troubleshootingk
Keyur Makwana
09/28/2023, 10:37 AMHey Team,
I have Flink job with CEP with pattern that implement below pattern rule
A followedBy B followedBy C followedBy D.
Now I have dynamic rule implemented in Job, If another rule want to match pattern like
A followedBy B followedBy C followedBy D followedBy E followedBy F
As far as I have understand if I am working with Datastream for CEP, i need to hardcode all the followedBy method i.e. I will need one method with 4 followedBy for 1st rule and another method with 5 followedBy for 2nd rule.
Can anybody help How can I implement dynamic number of followedBy clause of condition? One thing I saw is using CEP with Table API (SQL)
β
1
Keyur Makwana
10/02/2023, 8:04 AMHey
Any help will be very helpful to me
β
1
Keyur Makwana
10/04/2023, 7:26 AMSolved issue by writing my custom method while rule update using creating new pattern object
d
Damo
10/06/2023, 10:33 AMHi @Keyur Makwana do you have any more info on how you achieved this?
k
Keyur Makwana
10/06/2023, 1:24 PMConsider your CEP rule condition coming as a JSON object and first define normal pattern object now, if you have dynamic rule with broadcast you need custom logic with to create new pattern object while every new rule,