我有一个用例,我想用预先确定的开始时间和结束时间来计算窗口。例如,我想计算4月1日下午1点到4月7日下午1点钟之间的所有事件。
我想我可以计算每日窗口并保持结果的状态,但这似乎是最优的。
Flink是否支持在预先确定的开始和结束时间设置时间窗口?
似乎可以将其实现为批处理作业或有界流作业,只需将所有数据聚合在一起,而不是使用窗口,而是使用reduce或类似的方法。
我有一个用例,我想用预先确定的开始时间和结束时间来计算窗口。例如,我想计算4月1日下午1点到4月7日下午1点钟之间的所有事件。
我想我可以计算每日窗口并保持结果的状态,但这似乎是最优的。
Flink是否支持在预先确定的开始和结束时间设置时间窗口?
似乎可以将其实现为批处理作业或有界流作业,只需将所有数据聚合在一起,而不是使用窗口,而是使用reduce或类似的方法。
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