Hi Esa,

the SQL/CEP integration might be part of Flink 1.7. The discussion has just been started again [1].

Regards,
Timo

[1] https://issues.apache.org/jira/browse/FLINK-6935

Am 07.08.18 um 15:36 schrieb Esa Heikkinen:

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 ?

BR Esa

*From:*vino yang <yanghua1...@gmail.com>
*Sent:* Monday, July 23, 2018 3:00 PM
*To:* Esa Heikkinen <esa.heikki...@student.tut.fi>
*Cc:* Till Rohrmann <trohrm...@apache.org>; Chesnay Schepler <ches...@apache.org>; user <user@flink.apache.org>
*Subject:* Re: FlinkCEP and scientific papers ?

Hi Esa,

I think the core implementation pattern is still based that paper, there is a package named "nfa"[1] 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 and CEP.[2]

I think there is no newer paper related to current Flink CEP.

[1]: https://github.com/apache/flink/tree/master/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa

[2]: https://cwiki.apache.org/confluence/display/FLINK/FLIP-20:+Integration+of+SQL+and+CEP

Thanks, vino.

2018-07-23 16:05 GMT+08:00 Esa Heikkinen <esa.heikki...@student.tut.fi <mailto:esa.heikki...@student.tut.fi>>:

    Hi

    Thank you. This was very good paper for me J

    How much current FlinkCEP works like this (the paper was written
    2008) ?

    Are there exist newer papers related to current FlinkCEP ?

    BR Esa

    *From:*Till Rohrmann <trohrm...@apache.org
    <mailto:trohrm...@apache.org>>
    *Sent:* Wednesday, July 18, 2018 9:38 AM
    *To:* vino yang <yanghua1...@gmail.com <mailto:yanghua1...@gmail.com>>
    *Cc:* Esa Heikkinen <esa.heikki...@student.tut.fi
    <mailto:esa.heikki...@student.tut.fi>>; Chesnay Schepler
    <ches...@apache.org <mailto:ches...@apache.org>>; user
    <user@flink.apache.org <mailto:user@flink.apache.org>>
    *Subject:* Re: FlinkCEP and scientific papers ?

    You are right Vino,

    the initial implementation was based on the above mentioned paper.

    Cheers,

    Till

    On Tue, Jul 17, 2018 at 5:34 PM vino yang <yanghua1...@gmail.com
    <mailto:yanghua1...@gmail.com>> wrote:

        Hi Esa,

        AFAIK, the earlier Flink CEP refers to the Paper 《Efficient
        Pattern Matching over Event Streams》[1]. Flink absorbed  two
        major idea from this paper:

        1. NFA-b model on event stream

        2. a shared versioned match buffer which is a optimized data
        structure

        To Till and Chesnay:

        Did I missed anything when as time goes on and the development
        of Flink? If yes, please give your additional remarks.

        [1]:
        https://people.cs.umass.edu/~yanlei/publications/sase-sigmod08.pdf
        <https://people.cs.umass.edu/%7Eyanlei/publications/sase-sigmod08.pdf>

        Thanks, vino.

        2018-07-17 22:01 GMT+08:00 Esa Heikkinen
        <esa.heikki...@student.tut.fi
        <mailto:esa.heikki...@student.tut.fi>>:

            Hi

            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 ?

            BR Esa


Reply via email to