??????flink????????

Thu, 09 Jul 2020 08:36:18 -0700 

new ProcessWindowFunction?????????????
???????????????




------------------ ???????? ------------------
??????:                                                                         
                                               "user-zh"                        
                                                            
<[email protected]&gt;;
????????:&nbsp;2020??7??9??(??????) ????11:37
??????:&nbsp;"user-zh"<[email protected]&gt;;

????:&nbsp;flink????????



??????????????????????????????????????????????????????????????????
SingleOutputStreamOperator<Tuple2<warningPojo, String&gt;&gt; operator = 
flatMap.keyBy(0,1)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 .timeWindow(Time.minutes(1))
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 .process(new ProcessWindowFunction)
??????????????????????????????????????????????????????????????????????????????????????????????????????????????????

回复