Hi I did mean like “finding series of consecutive events”, as it was described in [2].
Are these features already in Flink and how well they are documented ? Can I use Scala or only Java ? I would like some example codes, it they are exist ? Best, Esa From: Fabian Hueske <fhue...@gmail.com> Sent: Tuesday, April 17, 2018 1:41 PM To: Esa Heikkinen <esa.heikki...@student.tut.fi> Cc: user@flink.apache.org Subject: Re: State-machine-based search logic in Flink ? Hi Esa, What do you mean by "individual searches in the Table API"? There is some work (a pending PR [1]) to integrate the MATCH_RECOGNIZE clause (SQL 2016) [2] into Flink's SQL which basically adds a SQL syntax for the CEP library. Best, Fabian [1] https://github.com/apache/flink/pull/4502 [2] https://modern-sql.com/feature/match_recognize 2018-04-17 10:07 GMT+02:00 Esa Heikkinen <esa.heikki...@student.tut.fi<mailto:esa.heikki...@student.tut.fi>>: Hi I am not sure I have understand all, but it is possible to build some kind of state-machine-based search logic for example on top of the individual searches in Table API (using CsvTableSource) ? Best, Esa
