??????
????????~
??????????????????????????????????????onelement????????????????????window??????,??????????????????window??maxTimeStamp????????????????window????????????????????




------------------ ???????? ------------------
??????: "Shi Quan"<qua...@outlook.com>;
????????: 2019??6??24??(??????) ????11:07
??????: "user-zh@flink.apache.org"<user-zh@flink.apache.org>;

????: RE: EventTimeTrigger??????????????????????????????????????????



Hi,
??????????????Window??State??Watermark??????????????????https://blog.csdn.net/xianzhen376/article/details/90415350

??????????????????????????????????????????????onWaterMark????????????????????????????????????????????????

  1.  registerEventTimeTimer 
??????????????????????????????????????????????????Queue????????namespace??key????????window.maxTimestamp????????window????Element
 event time??????window????????????????weindow????05:03????05:00-05:100?? 
maxTimeStamp??05:10??
  2.  
??????????????????????porcessWatermark????????????Queue????????????time????Watermark??????????????key??Window????????????????????????????????key
 ??????????
  3.  ????????????????????????????????????????????????current 
window????Element??????Window??????????time??????????????????
  4.  
????????????????time??????window??????????curWindow.maxTimestamp??????Element????key????????

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

Best,
Quan Shi

From: 840124434<mailto:840124...@qq.com>
Sent: Saturday, June 22, 2019 7:36 PM
To: user-zh<mailto:user-zh@flink.apache.org>
Subject: EventTimeTrigger??????????????????????????????????????????

[cid:62933D14@F8E87061.91120E5D]
??????????onElement??????????????????????????????????????????TriggerResult.FIRE 
,????????????registerEventTimeTimer??????????????????????????????????????????????
??????????onEventTime????????TriggerResult.FIRE????????????????????????????????????????????????????????????

回复