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

Wed, 08 Jul 2020 22:10:16 -0700 

Hi,


????????keyby?????????????????? warningPojo + String 
??????keyby????????????????????key??????????????????
????????????????????????????????????????????
???????????????????????? timestamp assigner 
????????????????????????????????????????


Best,
Yichao Yang




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

回复