我正在尝试使用 flink scala table api 加入两个表。我有一个带有两个(a,b)列的表和另一个带有一个(c)列的表我想将这两个表连接到一个具有三个(a,b,c)列的更大的表中。我只是想加入他们我不想使用任何条件(Where 子句)加入他们。但是Flink给我一个使用Where子句的错误,这是一种在where子句中没有任何条件的加入表的方法吗?如果我想使用 where 子句,我应该给出什么条件?
下面是我加入两个表的命令
val table_join = table1.join(table2).select("a,b,c").toDataset[res]
对正确方向的任何帮助都将受到高度赞赏。谢谢你。