flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "雷水鱼" <leishu...@daojia-inc.com>
Subject Flink 窗口触发疑问
Date Thu, 27 Jun 2019 07:13:22 GMT
 在 WindowOperator 类中
 processElement() 处理每一个到来的元素,我发现这里返回结果是fire的也能够触发窗口计算

TriggerResult triggerResult = triggerContext.onElement(element);
if (triggerResult.isFire()) {
   ACC contents = windowState.get();
   if (contents == null) {
      continue;
   }
   emitWindowContents(window, contents);}

onEventTime() 方法应该是由注册的定时器调用的,也能触发窗口计算

这下我就迷惑了,新来一条数据,达到了触发条件,这个窗口到底是由
processElement() 触发还是由定时器调用onEventTime()  触发的呢?


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message