我正在尝试使用flink scala表api连接两个表。我有一个表有两个(a,b)列和另一个表有一个(c)列，我想把这两个表连接到一个更大的表有三个(a,b, c)列。我只是想连接它们，我不想使用任何条件(Where子句)来连接它们。但Flink抛出我一个错误，使用Where子句，这是一种方式来连接表没有任何条件在Where子句?如果我想使用where从句，我应该给出什么条件?
下面是连接两个表的命令
val table_join = table1.join(table2).select("a,b,c").toDataset[res]
任何在正确方向上的帮助都是非常感激的。谢谢你。
Apache Flink的Table API连接是一个内部相等连接，需要至少一个相等谓词。
没有谓词的连接是交叉乘积。Flink的Table API不提供叉乘运算符，因为叉乘的计算非常昂贵。
使用Flink的DataSet API，可以使用交叉运算符或带有Broadcast集的映射函数计算交叉积。