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

[Yichao Yang]

Hi


??????????????????????????state????????????????uid 
keyby????????????????????????????????????????????BloomFilter????????????????????????????????????


Best,
Yichao Yang




------------------ ???????? ------------------
??????:&nbsp;"BenChen"<haibin...@163.com&gt;;
????????:&nbsp;2020??6??30??(??????) ????3:27
??????:&nbsp;"user-zh@flink.apache.org"<user-zh@flink.apache.org&gt;;

????:&nbsp;????RichReduceFunction??RichAggregateFunction





Hi all??
??flink????????????RichReduceFunction??RichAggregateFunction????????????UnsupportedOperationException??


????????????????reduce??aggregate??????????????????RichFunction????????????????????????ReduceFunction??AggregateFunction??????ReducingState??AggregatingState??????????????????????????????????????????state????????reduce??aggregate??????WindowFunction????????????


??????????????
1. 
??????Flink????????????????????????reduce??aggregate????RichFunction????????????????????
2. Flink??????RichReduceFunction??RichAggregateFunction????????????????
3. 
??????reduce??aggregate??????????????????????????????????state??????????BloomFilter??????????????????????????????????????????


??????
| |
BenChen
|
|
haibin...@163.com
|
??????????????????????