AI 助理
备案控制台
开发者社区 问答 正文

是否可以自定义trigger实现event time window的分散触发

如题，我目前计划自定义event time trigger实现分散触发。

比如0-5的窗口分散到6-11分触发， 从6开始是因为本身有个1min的乱序处理。

同时配合将allowedlateness设置为5min，这样避免窗口状态在触发之前被clean。*来自志愿者整理的flink邮件归档

展开
收起
塔塔塔塔塔塔 2021-12-02 15:18:19 820 分享 版权

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

1 条回答
写回答
取消 提交回答
  • EXCEED

    这样做是要达到设么目的呢? 目前的触发机制以及 early/late fire 满足不了需求么？*来自志愿者整理的FLINK邮件归档

    2021-12-02 15:42:51
    赞同 展开评论
问答分类：
流计算 实时计算 Flink版
问答地址：
开发者社区 > 大数据 > 问答
相关问答
StreamSQL 是否支持基于event time的事件窗口？
2599
0
0
大佬们，我自定义的state是根据我的window的生命周期走的吗？我的window结束了是不是我自
801
1
0
在 Trigger 里可以知道 Window 中数据的状况吗
1704
1
0
Session Window使用event time延迟特别高是怎么回事？
1154
1
0
Session Window使用event time延迟特别高是怎么回事呢？
1037
1
0
请教一下，flink的window的触发条件 watermark 小于 window 的 end_t
1585
1
0
如何实现event triggered window？
746
1
0
关于watermark和window是怎么触发计算的？
473
1
0
关于先基于process_time预聚合，再基于event_time聚合的问题。
744
1
0
使用GlobalWindows.create() 窗口，然后在自定义的trigger 中 操作按照自定义时间触发计算或清空操作 这样靠谱吗。
3535
1
0