如何使用Flink中的表API来消耗两个源流

Question

我有一个使用python表api的Flink Job。现在，我的应用程序将使用一个额外的源流。我很好奇使用表API消耗多个源流的推荐方法是什么。

附加信息：

这两个输入流只是事件的两个来源。我想通过窗口操作将它们聚合在一起。这就像DataStream 中的并集操作

谢谢！

Answer 1

相当于DataStream并集的Table/SQL是Table并集操作或SQL并集操作。