使用 Trigger.AvailableNow 进行有状态流操作
据我了解，在流模式下运行流作业时，状态会在窗口+水印期间保持，然后在无法再修改时写入。当我们使用 Trigger.AvailableNow 时，这会如何转化？它是否只是查看所有传入事件以获取新的最大时间戳，然后仅处理早于 max_event_time - window_time - Watermark 的事件？
As I understand, when running the streaming job in streaming mode the state is maintained during the window + watermark and then written when it can no longer be modified. How does this translate over to when we are using Trigger.AvailableNow? Does it just look at all the incoming events to get the new max timestamp and then only process events that are older than max_event_time - window_time - watermark?
如果你对这篇内容有疑问，欢迎到本站社区发帖提问 参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱，如果其他用户或者作者回复了您的评论，将不能在第一时间通知您！
发布评论