您好：
环境为最新的1.20的包，
目的就是想合并两个流，让两个流根据某个值关联，然后可以同时拿到两个流的数据，计算或保存使出一条数据，
一、发现pyflink是没有join的实现的
二、在使用connect的时候发现链接流里面的那几个函数实现都只有map1 2 或是 process_element1 2
文档里其他方法的实现也没有，只能处理各自流的数据，无法获取到其他流的数据。
想问下现在pyflink如何根据元素里的某个值去合并两个流，可以的话能投提供一个案例，谢谢。
