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

[??????]

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


??????


 




------------------ ???????? ------------------
??????:                                                                         
                                               "user-zh"                        
                                                            
<tsreape...@gmail.com&gt;;
????????:&nbsp;2021??11??8??(??????) ????1:54
??????:&nbsp;"flink??????????"<user-zh@flink.apache.org&gt;;

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



Hi??

?????????????????????????????????????????????????????????????????????????????? 
11:12:36 ~ 11:12:37 ????????

?????? <2572805...@qq.com.invalid&gt; ??2021??11??8?????? ????11:24??????

&gt; ??????:
&gt; 
????????assignTimestampsAndWatermarks??????eventTime??????????,??????????window(TumblingEventTimeWindows.of(Time.seconds(1))).process(...)
&gt; ??????1????????????????????????
&gt; 
????????????????????print??????????,????????????????context.window().getEnd()????????????????????,????????????
&gt; ??????????1s??
&gt; ????:
&gt; ==============&amp;gt; ResultBean(key=ZYSZ000001, count=2,
&gt; timestamp=1636341155000, datetime=2021-11-08 11:12:35,
&gt; indicator=elevator.analysis.sum.floor, userablerate=null,
&gt; sumofflinetime=null, forusetime=null, producttime=null)
&gt; ==============&amp;gt; ResultBean(key=ZYSZ000001, count=3,
&gt; timestamp=1636341158000, datetime=2021-11-08 11:12:38,
&gt; indicator=elevator.analysis.sum.floor, userablerate=null,
&gt; sumofflinetime=null, forusetime=null, producttime=null)
&gt; ==============&amp;gt; ResultBean(key=ZYSZ000001, count=5,
&gt; timestamp=1636341159000, datetime=2021-11-08 11:12:39,
&gt; indicator=elevator.analysis.sum.floor, userablerate=null,
&gt; sumofflinetime=null, forusetime=null, producttime=null)
&gt;
&gt;
&gt; ????:
&gt;&nbsp;&nbsp; ??????????????????1s??????,??????????????????1s???????
&gt;
&gt; ??????
&gt;
&gt;
&gt; &amp;nbsp;