Apache Beam 中的固定窗口何时启动？
相关标签： # docker
我有一份固定窗口策略的加入工作。因此join作业从两个流中读取：
1. Record 1: ts: 2022-Mar-23-13:00:00, key: abcdef
2. Record 2: ts: 2022-Mar-23-18:00:00, key: xyzefg
如果我使用24小时的固定窗口，并且我一直从数据流中读取数据，Record1和Record2的窗格何时启动？
对吗？
Pane1: start = 2022-Mar-23-13:00:00, end = 2022-Mar-24-13:00:00, key =abcdef
Pane2: start = 2022-Mar-23-18:00:00, end = 2022-Mar-24-18:00:00, key= xyzefg
或者这是正确的？
Pane1: start = 2022-Mar-23-13:00:00, end = 2022-Mar-24-13:00:00, key =abcdef
Pane2: start = 2022-Mar-23-13:00:00, end = 2022-Mar-24-13:00:00, key= xyzefg
或者这是正确的？
Pane1: start = 2022-Mar-23-00:00:00, end = 2022-Mar-24-00:00:00, key =abcdef
Pane2: start = 2022-Mar-23-00:00:00, end = 2022-Mar-24-00:00:00, key= xyzefg
特别声明：以上内容（图片及文字）均为互联网收集或者用户上传发布，本站仅提供信息存储服务！如有侵权或有涉及法律问题请联系我们。
举报
