The basic structure of the Scala code in Flink CEP application

Question

I have tried to understand how to CEP in Flink works. For example from pages: DataArtisans LongRides and Flink CEP 1.4.

I would like to know what is the basic structure of the (Scala) code in Flink CEP application ?

What (mandatory) parts, classes, functions/methods and so on should be used and in what order ?

I think the basic parts could be: 1. pattern definition 2. pattern stream definition (or is it possible to use many parallel streams ?) 3. select definition Is that correct ?

And how to use the "select part" and how to find more information about it ? It seem to be quite complex.

Answer 1

The structure that you've written is basically correct. You need to define pattern and stream of events that you want to apply that pattern to. Then you should apply select function which allows you to apply some logic to events that constitute a match.

The best source to get more info how the FlinkCEP works is its documentation.