?????? flink????????GMV,??????????????????????????????

[????????]

??????1?????????????????????????
??????1.11+??????sql????????????????????update_before????????????update_after?????????
???????????????????????????????Flink????????????after??????before??
????.




------------------ ???????? ------------------
??????:                                                                         
                                               "user-zh"                        
                                                            
<libenc...@apache.org&gt;;
????????:&nbsp;2020??9??9??(??????) ????1:09
??????:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

????:&nbsp;Re: flink????????GMV,??????????????????????????????



??????????????SQL????DataStream API????????????SQL????????????????????????
1. ??????????1.11+?? ??????????binlog
format????????????????????????????????update_before??update_after????????????Flink
&nbsp; ??????????????????????????????????????????????????????select sum(xxx) 
from T group by
yyy????????????sum??????????????????????
2. ????????binlog????????????????????????????????????????????????????[1] 
??append??????????retract??????????????????????????
&nbsp; ??????????????????????????

[1]
https://ci.apache.org/projects/flink/flink-docs-master/dev/table/sql/queries.html#deduplication


xuzh <x...@chyjr.com&gt; ??2020??9??8?????? ????5:56??????

&gt; ??????
&gt; &amp;nbsp; &amp;nbsp;??????????????GMV,????????????????????????
&gt; &amp;nbsp; 
??????????mysql,????binlog??????????????????kafka.??????kafka??????????????????????
&gt; &amp;nbsp; ????????009 ????10??????????????1000. ????????json??????kafka 
,GMV??????????1000.
&gt; &amp;nbsp; ????????15????009????????????????500??????????json????????kafka.
&gt; ??????????????????????????????????????????????????????&amp;nbsp;&amp;nbsp;
&gt; ?????????????? update /delete 
??????????????????????????????????????????????????????????????????????????????????????????????
&gt;
&gt;
&gt; &amp;nbsp; ??????????????????????????



-- 

Best,
Benchao Li