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

Sun, 07 Nov 2021 19:24:04 -0800 

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


????:
  ??????????????????1s??????,??????????????????1s???????

??????


 

回复