什么是窗口标准?

问题描述

Apache Spark是基于时间的窗口条件,而Flink是基于记录的窗口条件。

任何机构都可以详细解释什么是窗口标准?

解决方法

根据条件,它们表示谓词或条件。例如,每2分钟触发一次窗口。 Flink的要点是Flink是基于记录的流引擎。它一次处理每个记录。尽管Spark具有微批次,但它在微批次的时间范围内处理所有事件。 Flink具有滚动,滑动,会话和全局窗口的概念。

下面的链接(https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/operators/windows.html#window-assigners)中有简短说明。但是您可以在链接上找到带有数字的详细说明。

滚动窗口分配器将每个元素分配给指定窗口大小的窗口。 滑动窗口分配器将元素分配给固定长度的窗口。 会话窗口分配器按活动会话对元素进行分组。 全局窗口分配器将具有相同键的所有元素分配给同一单个全局窗口。

相关问答

错误1:Request method ‘DELETE‘ not supported 错误还原:...
错误1:启动docker镜像时报错:Error response from daemon:...
错误1:private field ‘xxx‘ is never assigned 按Alt...
报错如下,通过源不能下载,最后警告pip需升级版本 Requirem...