RE: State-machine-based search logic in Flink ?

Posted by Esa Heikkinen on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/State-machine-based-search-logic-in-Flink-tp19568p19595.html

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 <[hidden email]>
Sent: Tuesday, April 17, 2018 1:41 PM
To: Esa Heikkinen <[hidden email]>
Cc: [hidden email]
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 <[hidden email]>:

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