???????? ?????????? keyby ???????????????????????????? sourceDataStream .keyBy(id) .window(TumblingEventTimeWindows.of(Time.seconds(10L))) .reduce() .print() ??????????id ??1~1500??????id?????????????????????? eventtime????????????????????id??1??eventtime????20???????????????????????? ?????????????????????????????????????????????????????????????? ???????????? ????????id??1???????????? id=1??????????????????
????
