我有两个流，并希望将第二个流加入窗口中的第一个流，因为我需要对与会话相关的两个流的连接进行一些计算（其中的两个流控制会话）。
实际上，从文档中可以看到，（会话）窗口仅允许对单个流进行计算，而不能进行联接。
我尝试使用会话窗口和协处理器功能的组合，但结果与我期望的不完全相同。
有没有一种方法可以合并与Flink中的会话窗口相关的两个流？
弗林克的的数据流中的API包括会话窗口加盟，这说明这里。
您必须查看其语义是否符合您的想法。会话间隔由在该时间间隔内没有事件的两个流定义，并且该联接是内部联接，因此，如果会话窗口仅包含一个流中的元素，则不会发出任何输出。
如果那不能满足您的需求，那么我建议您使用CoProcessFunction，但是没有会话窗口。换句话说，我建议您可以自己实现所有逻辑。
本文收集自互联网，转载请注明来源。
如有侵权，请联系 [email protected] 删除。
我来说两句