?????? ????????????????????????????????????????

Mon, 19 Oct 2020 03:24:02 -0700 

??????????????KeyedProcessFunction????ProcessWindowFunction.




------------------ ???????? ------------------
??????:                                                                         
                                               "user-zh"                        
                                                            
<[email protected]&gt;;
????????:&nbsp;2020??10??19??(??????) ????3:28
??????:&nbsp;"user-zh"<[email protected]&gt;;

????:&nbsp;Re: ????????????????????????????????????????



Hi
&nbsp;&nbsp;&nbsp;&nbsp; ?????????????? timer 
?????????????????????????????????? timer?????? timer ???????????? state ??????
Best,
Congxian


x <[email protected]&gt; ??2020??10??19?????? ????2:55??????

&gt; ??????v1.10.1
&gt; 
????AggregateFunction+ProcessWindowFunction??????????????????????ProcessWindowFunction??????????????????????????????????????????+????????????????????????????????????????????????????????????????????????????????ProcessWindowFunction??clear??????????????????????????????23??59??00??????????override
&gt; def clear(ctx: Context): Unit = {
&gt;&nbsp;&nbsp; val dt = new 
SimpleDateFormat("HH:mm:00").format(ctx.window.getStart)
&gt;&nbsp;&nbsp; if(dt.equals("23:59:00")){
&gt;
&gt; 
state.clear()??????????????????????????keyBy????????????key????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????

回复