Re: flink 1.9 自定义UDAF 实现state管理的逻辑吗？

2020-06-07 文章 Benchao Li
也做checkpoint > > > > > -- 原始邮件 -- > 发件人: "Benchao Li" 发送时间: 2020年6月8日(星期一) 上午10:46 > 收件人: "user-zh" > 主题: Re: flink 1.9 自定义UDAF 实现state管理的逻辑吗？ > > > > 没有完全明白你的问题。 > 你是要问UDAF的相关的state是怎么被Flink管理的么？ > 还是问UDAF里面如果用了state，应

Re: flink 1.9 自定义UDAF 实现state管理的逻辑吗？

2020-06-07 文章 Benchao Li
没有完全明白你的问题。 你是要问UDAF的相关的state是怎么被Flink管理的么？ 还是问UDAF里面如果用了state，应该自己怎么来管理呢？ star <3149768...@qq.com> 于2020年6月8日周一 上午10:44写道： > 请教大家， > > > flink 1.9 自定义UDAF 实现state管理的逻辑吗？ > > > 还是和sql一样 自己管理stage？ > > > class MyFunc extends AggregateFunction{ > createAccu