Simple Example for Flink Java

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

Simple Example for Flink Java

Neelesh Salian-2
Hi,

I have a java program in a jar that parses some Spark Api and does a distcp action.
I intend to add a window / interval of 5 mins (arbitrary time) for this jar to execute and do the function.

What's the easiest way to make a window and run the above jar in it and make sure it runs every 5 mins? 
The UI would help me keep track of things.

Suggestions / pointers? 

Thank you in advance.

--
Regards,
Neelesh S. Salian