hi,all 我有一个场景是使用自定义的ScalaFunction实现所需要的look up功能(从数据库查询并将多行数据拼成一个数组)。 我正在试图尝试使用异步IO的方式以提高它的性能,但是似乎只有Stream API提供了该特性支持。 大家有什么建议吗?或者有其他优化思路吗? 谢谢!
-- Sent from: http://apache-flink.147419.n8.nabble.com/
hi,all 我有一个场景是使用自定义的ScalaFunction实现所需要的look up功能(从数据库查询并将多行数据拼成一个数组)。 我正在试图尝试使用异步IO的方式以提高它的性能,但是似乎只有Stream API提供了该特性支持。 大家有什么建议吗?或者有其他优化思路吗? 谢谢!
-- Sent from: http://apache-flink.147419.n8.nabble.com/