问题描述
Apache Spark是基于时间的窗口条件,而Flink是基于记录的窗口条件。
任何机构都可以详细解释什么是窗口标准?
解决方法
根据条件,它们表示谓词或条件。例如,每2分钟触发一次窗口。 Flink的要点是Flink是基于记录的流引擎。它一次处理每个记录。尽管Spark具有微批次,但它在微批次的时间范围内处理所有事件。 Flink具有滚动,滑动,会话和全局窗口的概念。
下面的链接(https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/operators/windows.html#window-assigners)中有简短说明。但是您可以在链接上找到带有数字的详细说明。
滚动窗口分配器将每个元素分配给指定窗口大小的窗口。 滑动窗口分配器将元素分配给固定长度的窗口。 会话窗口分配器按活动会话对元素进行分组。 全局窗口分配器将具有相同键的所有元素分配给同一单个全局窗口。