Re: AsyncDataStream on key of KeyedStream

[Flavio Pompermaier]

For each key I need to call an external REST service to get the current
status and this is why I'd like to use Async IO. At the moment I do this in
a process function but I'd like a cleaner solution (if possible).
Do you think your proposal of forking could be a better option?
Could you provide a simple snippet/peudo-code of it? I'm not sure I've
fully undestand your suggestion..