Hi Esa, you can also read files as a stream. However, you have to be careful in which order you read the files and how you generate watermarks. The easiest approach is to implement a non-parallel source function that reads the files in the right order and generates watermarks. Things become more tricky when you try to read the files in parallel.
Best, Fabian 2018-02-07 9:40 GMT+01:00 Esa Heikkinen <esa.heikki...@student.tut.fi>: > Hello > > > > I am trying to use CEP of Flink for log files (as batch job), but not for > streams (as realtime). > > Is that possible ? If yes, do you know examples Scala codes about that ? > > > > Or should I convert the log files (with time stamps) into streams ? > > But how to handle time stamps in Flink ? > > > > If I can not use Flink at all for this purpose, do you have any > recommendations of other tools ? > > > > I would want CEP type analysis for log files. > > > > >
