Thanks for the hints, but I am still very interested about simple working 
example with combination: sbt-project, scala, csv-file reading and cep 
processing. I have did not exactly find something like that. It would help me a 

It takes lot of time to learn and test many possible code combinations.. Too 
many “moving” parts..
For example “huge” amount of different “imports” and where I can find how use 
them and so on ?
I did not find strict “reference” guide. For example for readCsvFile(). Or 
should I look it from code ?

By the way what is better to use maven or sbt ? It seems most of examples use 
maven, but I haven’t got maven to work properly (yet) ..

Best Regards

From: Timo Walther [mailto:twal...@apache.org]
Sent: Thursday, February 8, 2018 7:23 PM
To: user@flink.apache.org
Subject: Re: CEP for time series in csv-file

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:



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 

Some pointers are the following:

CEP documentation: 

Blog post with CEP example: 


On Feb 8, 2018, at 4:28 PM, Esa Heikkinen 
<esa.heikki...@student.tut.fi<mailto:esa.heikki...@student.tut.fi>> wrote:


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 ?

Reply via email to