Flink 在会话窗口中加入两个流

我有两个流，并希望在窗口中将第二个流加入第一个流，因为我需要对与会话相关的两个流的连接进行一些计算(在流上管理会话(。

实际上，从文档中读到，(会话(窗口仅允许对单个流进行计算，而不是在连接中。

我尝试使用会话窗口和协处理器功能的组合，但结果并不完全是我预期的。

有没有办法合并与 Flink 中的会话窗口相关的两个流？

Flink 的 DataStream API 包含一个会话窗口连接，描述如此。

你必须看看它的语义是否与你的想法相匹配。会话间隙由在该间隔内没有事件的两个流定义，并且联接是内部联接，因此如果会话窗口仅包含一个流中的元素，则不会发出任何输出。

如果这不能满足您的需求，那么我建议使用 CoProcessFunction，但没有会话窗口。换句话说，我建议你可以自己实现所有的逻辑。

相关内容