??????????

????????uid 
keyby????????????????????????????reduce??aggregate????????state????BloomFilter????????WindowFunction??????state????????????????process????????????????????????????????????????????????????


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


??2020??06??30?? 15:55??Yichao Yang<1048262...@qq.com> ??????
Hi


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


Best,
Yichao Yang




------------------&nbsp;????????&nbsp;------------------
??????:&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
|
??????????????????????

Reply via email to