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.


Reply via email to