use of RichAsyncFunction as a FlatMap
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
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
re
