如何使用Flink中的表API使用两个源流
我有一份使用python表api的Flink工作。现在，我的应用程序将使用额外的源流。我很好奇，使用表API消费多个源流的推荐方法是什么。
其他信息：
这两个输入流只是两个事件源。我想通过窗口操作将它们聚合在一起。这就像DataStream中的联合操作
谢谢
共有1个答案
与DataStream union等效的表/SQL是表union操作或SQL union操作。
-
我试图将数据从kafka主题读入DataStream并注册DataStream，然后使用tableEnvironment.sqlQuery（“sql”）查询数据，当tableEnvironment.execute（）没有错误也没有输出时。 依赖关系： flink-streaming-java2.11版本:1.9.0-csa1.0.0.0； Flink-Streaming-Scala2.11版本:1
-
我有两条小溪。它们都是1小时窗口内的聚合数据。我想压缩这些流，以便将相同时间跨度上的聚合组合在一起，如果现在存在这样的对应匹配，则可能使用空值。 我怎样才能做到这一点？
-
我尝试在spring boot中使用两个DataSource，并按照教程配置:http://docs.spring.io/spring-boot/docs/1.3.1.release/reference/htmlsingle/#howto-two-dataSources 然后创建2个实体和2个存储库
-
问题内容： 我开始将DataTables Table插件用于jQuery ，但遇到了一些问题。我从这里使用示例代码。 我有MySQL表女巫看起来像这样： id | 名称| Father_id 是同一表中仅在不同行中的值。因此，如果我想知道父亲的名字，我必须在同一个表中进行搜索。但是DataTable所做的只是按原样显示MySQL表的内容。 在我的数据表中，我想显示如下数据： id | 名称| 父亲
-
问题内容： 我有以下两个列表 我想要做的是像这样打印这两个列表 使用经典方式很容易做到 有没有一种方法可以使用Stream API Java 8？ 我能做的是只打印一个清单 问题答案： 最简单的方法是创建一个来生成索引，然后将每个索引映射到您要创建的索引。 另外，您可能对这个SO问题感兴趣，使用带有lambda的JDK8压缩流（java.util.stream.Streams.zip），因为这是您