Hi Howard,
I don’t think there is a rich variant for Async IO in Scala yet. We should
perhaps add support for it.
Looped in Till who worked on the Async IO and its Scala support to clarify
whether there were any concerns in not supporting it initially.
Cheers,
Gordon
On February 13, 2017 at
Hi,
I’m going to test async IO of scala version. As we can see in
https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/stream/asyncio.html.
The java version of async IO API has method of open and close, in which I can
do some init and clean work. The scala api, however, has
