Flink Sink 接收数据的顺序(Window发送数据顺序)

  • 时间:
  • 浏览:0
  • 来源:uu快3大小_uu快3网站_开奖历史

triggerTarget.onProcessingTime(timer);// 调用 WindowOperator.onProcessingTime(timer)避免

把当前元素增加到state中保存,add函数中会对相同key进行聚合操作(reduce),对同另一1个 window中相同key进行求和而是在这人方式中进行的

顶端发送给Sink的数据,而是遍历这人processingTimeTimersQueue中的数据,当然,每次发送第另一1个 元素,发送后,会把最后另一1个 元素倒进第另一1个 元素

此时发另另一1个 的数据格式发送

WindowOperator.processElement,给每另一1个 WordWithCount(1,1) 另另一1个 的元素分配window,也而是确认每另一1个 元素属于哪另一1个 窗口,可能时需对同另一1个 窗口的相同key进行聚合操作

Key,避免的顺序,如 1 2 3 5 4,就会变成