关于RichReduceFunction和RichAggregateFunction

2020-06-30 Thread BenChen
的问题是 1. 是否从Flink设计角度来说,就不支持在reduce和aggregate使用RichFunction?还是说以后会实现? 2. Flink自带的RichReduceFunction和RichAggregateFunction是用在什么场景? 3. 在使用reduce和aggregate聚合的过程中,如果我需要一些全局的state,比如使用BloomFilter判断用户是否参与过这个活动,有什么建议吗? 感谢。 | | BenChen | | haibin...@163.com | 签名由网易邮箱大师定制

??????????RichReduceFunction??RichAggregateFunction

2020-06-30 Thread BenChen
?? uid keybyreduce??aggregatestateBloomFilterWindowFunction??stateprocess | | BenChen | | haibin...@163.com | ?? ??2020??06??30?? 15:55