I was wondering if there is a way to create an asynchronous flatmap function in Flink.
As far as I am aware, the asynchronous function only accepts a single result future as its return (which can be the aggregate list of the flatmap, but then partiality is lost as we have to wait for all of the results to be aggregated before returning). Alternatively, using a normal FlatMap seems to require a way to keep the current instance alive as it waits for the results and emits them one at a time, as otherwise Flink may consider it terminated (as the function call returns immediately) and close the channel. Is there some third option I am unaware of (or using one of the above two in a different way?), Cheers. -- Konstantinos Barmpis | Research Associate White Rose Grid Enterprise Systems Group Dept. of Computer Science University of York Tel: +44 (0) 1904-32 5653 Email Disclaimer: http://www.york.ac.uk/docs/disclaimer/email.htm
