什么是窗口标准?

aydmsdu9  于 2021-05-27  发布在  Spark
关注(0)|答案(1)|浏览(375)

apachespark是基于时间的窗口标准,flink是基于记录的窗口标准。
任何机构都可以详细解释什么是窗口标准?

hgc7kmma

hgc7kmma1#

他们所说的标准是指一个 predicate 或一个条件。例如,每2分钟触发一个窗口。flink的重点是flink是一个基于记录的流引擎。它一次处理每条记录。而spark有微批处理,它处理微批时间范围内的所有事件。flink有翻滚、滑动、会话和全局窗口的概念。
下面是链接的简短解释(https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/operators/windows.html#window-转让人)。但你可以在链接上找到带有数字的详细说明。
滚动窗口赋值器将每个元素分配给指定窗口大小的窗口。滑动窗口指定器将元素指定给固定长度的窗口。会话windows赋值器按活动会话对元素进行分组。全局窗口赋值器将具有相同键的所有元素分配给同一个全局窗口。

相关问题