CEP - Interval between patterns

2023-07-09 Thread Ana Gómez González
expected val getPattern: Pattern[Measure, Measure] = > Pattern > .begin[Measure]("a1-communication-error") > .within(Time.minutes(3)) //this has been reduced for testing purposes > .notFollowedBy("a2-communication-error") Thank you so much always for your time

Re: Debug CEP Patterns

2023-04-20 Thread Ana Gómez González
Thanks Biao, your insights were very helpful for me! I finally could debug properly, a couple of things were not correct there, in fact. Also, I think I'm not modeling properly the behaviour of the pattern so I definitely going to investigate better this. Regards *Ana Gómez González*

Re: Debug CEP Patterns

2023-04-18 Thread Ana Gómez González
Here's a link for the previous code in a gist so you don't struggle with the format. Sorry. https://gist.github.com/angoglez/d9eb6e12f259aba306387b5c23488fb4 >

Debug CEP Patterns

2023-04-18 Thread Ana Gómez González
): Unit = { System.out.println("PROCESSING MATCH") val pattern1: HourlyReading = patterns.get("a1-nighttimeflowfraud").get(0) val pattern2: HourlyReading = patterns.get("a2-nighttimeflowfraud").get(0) System.out.println(pattern1) System.out.println(pattern2) //case

Re: Create generic DeserializationSchema (Scala)

2023-03-08 Thread Ana Gómez González
Thank you Alexey! It worked perfectly. I was missing the ClassTag correct use. *Ana Gómez González* <http://twitter.com/angoglez> <https://www.linkedin.com/in/angoglez/> El lun, 6 mar 2023 a las 23:34, Alexey Novakov () escribió: > Hi Ana, > > I think you will need to

Create generic DeserializationSchema (Scala)

2023-03-06 Thread Ana Gómez González
ypes and TypeInformation class, but I don't get the correct use or if it can be used for my purpose. Thanks a lot in advance *Ana Gómez González* <http://twitter.com/angoglez> <https://www.linkedin.com/in/angoglez/>