Hi guys, I want to bring up a discussion about adding support of User Defined AsyncTableFunction in Flink. Currently, async table function are special functions for table source to perform async lookup. However, it's worth to support the user defined async table function. Because, in this way, the end SQL user can leverage it to perform the async operation which is useful to maximum the system throughput especially for IO bottleneck case.
You can find some more detail in [1]. Looking forward to feedback [1]: https://cwiki.apache.org/confluence/display/FLINK/%5BFLIP-313%5D+Add+support+of+User+Defined+AsyncTableFunction Thanks, Aitozi.