streaming - 这种窗口模式中键的目的是什么？

Question

参考什么键？在滑动窗口的情况下是否有使用示例？

标签： streamingapache-beamwindowing

Answer 1

这些键基本上允许您将输入流中的数据逻辑地组合在一起。

这可以允许处理优化，因为窗口内的分组（按键）数据可以与流中的其他组并行独立处理。

作为一个很好的例子，来自 Apache Link 文档 ( https://flink.apache.org/news/2015/12/04/Introducing-windows.html )，流可能包含流量传感器读数，您可能需要 30 秒的窗口- 即每 30 秒通过传感器的流量计数。

如果您有多个传感器，您可以使用传感器 ID 键入数据，并计算每 30 秒通过每个传感器的流量以及总数。