如题,我目前计划自定义event time trigger实现分散触发。 比如0-5的窗口分散到6-11分触发, 从6开始是因为本身有个1min的乱序处理。 同时配合将allowedlateness设置为5min,这样避免窗口状态在触发之前被clean。
不知道想法是否OK呢?
如题,我目前计划自定义event time trigger实现分散触发。 比如0-5的窗口分散到6-11分触发, 从6开始是因为本身有个1min的乱序处理。 同时配合将allowedlateness设置为5min,这样避免窗口状态在触发之前被clean。
不知道想法是否OK呢?