flink scala table api を使用して 2 つのテーブルを結合しようとしています。2 つの (a,b) 列を持つ 1 つのテーブルと 1 つの (c) 列を持つ別のテーブルがあり、2 つのテーブルを 3 つの (a、b、c) 列を持つ大きなテーブルに結合したいと考えています。私は単にそれらに参加したいのですが、それらに参加するために条件(Where句)を使用したくありません。しかし、Flink は Where 句を使用するとエラーをスローします。それは、where 句で条件なしでテーブルを結合する方法ですか? where 句を使用したい場合、どのような条件を指定すればよいですか?
以下は、2つのテーブルを結合するための私のコマンドです
val table_join = table1.join(table2).select("a,b,c").toDataset[res]
正しい方向への助けは大歓迎です。ありがとうございました。