Any insight about this? On Tue, May 26, 2015 at 5:58 PM, Flavio Pompermaier <pomperma...@okkam.it> wrote:
> Hi to all, > > In my program I'd like to infer from a mysql table the list of directory I > have to output on hdfs (status=0). > Once my job finish to clean each directory and update the status value of > my sql table. > How can I do that in Flink? Is there any callback on the dataset.output() > finish? > > Best, > Flavio >
