Apache Flink:是否可以实现依赖于多个键的窗口触发器



我可以在 Flink 中编写一个自定义触发策略,通过查看一组键而不仅仅是单个键来决定发射吗?

No.Flink 的"触发器"共享在它自己的任务管理器中。不能在触发器中保留任何内部状态,否则副作用未知。这已经在 Trigger.java 的评论中得到了证明。