There was one good example of pattern query in
the paper made by SASE+ language (in attachment).
Could you easily say how to do that FlickCEP
with Scala ? Or is it possible ?
That SQL and CEP would also be very
interesting, but when it is ready to use ?
From: vino yang <yanghua1127@xxxxxxxxx>
Sent: Monday, July 23, 2018 3:00 PM
To: Esa Heikkinen
Cc: Till Rohrmann <trohrmann@xxxxxxxxxx>;
Chesnay Schepler <chesnay@xxxxxxxxxx>; user
Subject: Re: FlinkCEP and scientific papers ?
I think the core implementation pattern
is still based that paper, there is a package named
"nfa" contains the main thought.
The latest CEP module added more
features and enhanced the old versio. What's more, there
is a FLIP-20 which has been
accepted, it described how to integrate with SQL
I think there is no newer paper related
to current Flink CEP.
2018-07-23 16:05 GMT+08:00 Esa
Thank you. This was very good paper
How much current FlinkCEP works like
this (the paper was written 2008) ?
Are there exist newer papers related
to current FlinkCEP ?
From: Till Rohrmann <trohrmann@xxxxxxxxxx>
Sent: Wednesday, July 18, 2018 9:38 AM
To: vino yang <yanghua1127@xxxxxxxxx>
Cc: Esa Heikkinen <esa.heikkinen@xxxxxxxxxxxxxx>;
Chesnay Schepler <chesnay@xxxxxxxxxx>;
Subject: Re: FlinkCEP and scientific papers
are right Vino,
initial implementation was based on the
above mentioned paper.
the earlier Flink CEP refers to the
Pattern Matching over Event Streams》. Flink
absorbed two major idea from this paper:
NFA-b model on event stream
a shared versioned match buffer which is
a optimized data structure
I missed anything when as time goes on
and the development of Flink? If yes,
please give your additional remarks.
22:01 GMT+08:00 Esa Heikkinen <esa.heikkinen@xxxxxxxxxxxxxx>:
I don’t know this
the correct forum to ask, but
are there exist some good
scientific papers about FlinkCEP
(Complex Event Processing) ?
I know Flink is
based to Stratosphere, but how
is it FlinkCEP ?