为什么Flink流不支持左连接表达式？

Question

Flink Stream支持内部连接表达式，如窗口连接，间隔连接。但不支持左连接/完全连接表达式。当然，窗口共组表达式可以实现相同的语义，即使事件已立即加入，也必须等待完全窗口大小的时间。我的问题是：

1. 如何从设计角度解释Flink Stream不支持左连接/全连接说明？
2. 我如何通过Flink DataStream API实现它（如果可以立即转发加入事件会更好）？
3. 有没有办法扩展Flink DataStream API以支持左连接，例如：

.leftJoin()
.where()
.window()
.apply()

Answer 1

时间约束联接（如窗口联接或间隔联接）与常规联接之间的区别在于，在流上下文中，常规联接需要无限状态保留。

使用Flink的表和SQL APIs可以使用常规的左/全连接。Flink社区一直在努力的方向是不再用数据流API开发关系操作，而是提高数据流和表API之间的互操作性。Flink 1.13标志着一个新的里程碑，它使得流和表之间的相互转换更加容易，每当需要对数据流进行关系操作时，这是推荐的方法。