关于Flink SQL UDAF中调用createAccumulator的调用问题

Tue, 21 Apr 2020 02:37:26 -0700 

Hi all,



   最近有几个疑问没能很好地理解清楚：



   我们都知道，UDAF中的有createAccumulator这个方法，那么：

这个方法的调用时机是什么呢，会被调用几次呢？

一个accumulator的生命周期是怎么样的？

一个accumulator会被反复的序列化反序列化吗？


 麻烦了解相关细节的社区的同学们帮忙解答一下~

先谢谢啦

回复