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

  • 时间:
  • 浏览:1
  • 来源:5分PK10_5分PK10官网

把当前元素增加到state中保存,add函数中会对相同key进行聚合操作(reduce),对同一有一两个多window中相同key进行求和可是我在你这些办法 中进行的

triggerTarget.onProcessingTime(timer);// 调用 WindowOperator.onProcessingTime(timer)正确处理

WindowOperator.processElement,给每一有一两个多WordWithCount(1,1) 以前的元素分配window,也可是我确认每一有一两个多元素属于哪一有一两个多窗口,或者不需要 对同一有一两个多窗口的相同key进行聚合操作

Key,正确处理的顺序,如 1 2 3 5 4,就会变成

此时发以前的数据格式发送

底下发送给Sink的数据,可是我遍历你这些processingTimeTimersQueue中的数据,当然,每次发送第一有一两个多元素,发送后,会把最后一有一两个多元素放进第一有一两个多元素