State-machine-based search logic in Flink ?

[Esa Heikkinen]

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

 

[Fabian Hueske-2]

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

 

[Esa Heikkinen]

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

 

 

[Fabian Hueske-2]

As I said before, this is work in progress and there is a pending pull request (PR) to add this feature.
So no, MATCH_RECOGNIZE is not supported by Flink yet and hence also not documented.

Best, Fabian

2018-04-18 10:12 GMT+02:00 Esa Heikkinen <[hidden email]>:

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