0

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

附加信息：

两个输入流只是两个事件源。我想将它们与窗口操作聚合在一起。就像DataStream 中的联合操作

谢谢！

4

1 回答 1

2

与 DataStream union 等效的 Table/SQL 是Table union operation或SQL union operation。

于 2021-11-06T10:11:42.587 回答