You can also take a look at the Flink training from data Artisans and
the code examples there. They also use CEP and basically read also from
a file:
http://training.data-artisans.com/exercises/CEP.html
Regards,
Timo
Am 2/8/18 um 6:09 PM schrieb Kostas Kloudas:
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
Blog post with CEP example:
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 <mailto: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 ?
