Hi Esa, I think the best place to start is the documentation available at the flink website.
Some pointers are the following: CEP documentation: https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/libs/cep.html <https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/libs/cep.html> Blog post with CEP example: https://data-artisans.com/blog/complex-event-processing-flink-cep-update <https://data-artisans.com/blog/complex-event-processing-flink-cep-update> Cheers, Kostas > On Feb 8, 2018, at 4:28 PM, Esa Heikkinen <esa.heikki...@student.tut.fi> > wrote: > > Hi > > I have cvs-file(s) that contain an event in every row and first column is > time stamp of event. Rest of columns are data and “attributes” of event. > > I’d want to write simple Scala code that: 1) reads data of csv-file 2) > converts data of csv-file compatible for CEP 3) sets pattern for CEP 4) Runs > CEP 5) writes results > > Do you have any hints or examples how to do that ? > > By the way, what kind of time stamp should be in csv-file ?
