我可以在 Flink 中编写一个自定义触发策略,通过查看一组键而不仅仅是单个键来决定发射吗?
No.Flink 的"触发器"共享在它自己的任务管理器中。不能在触发器中保留任何内部状态,否则副作用未知。这已经在 Trigger.java 的评论中得到了证明。
我可以在 Flink 中编写一个自定义触发策略,通过查看一组键而不仅仅是单个键来决定发射吗?
No.Flink 的"触发器"共享在它自己的任务管理器中。不能在触发器中保留任何内部状态,否则副作用未知。这已经在 Trigger.java 的评论中得到了证明。
javascript python java c# php android html jquery c++ css ios sql mysql arrays asp.net json python-3.x ruby-on-rails .net sql-server django objective-c excel regex ruby linux ajax iphone xml vba spring asp.net-mvc database wordpress string postgresql wpf windows xcode bash git oracle list vb.net multithreading eclipse algorithm macos powershell visual-studio image forms numpy scala function api selenium