問題タブ [flink-sql]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
apache-flink - テーブル API スカラ
flink scala table api を使用して 2 つのテーブルを結合しようとしています。2 つの (a,b) 列を持つ 1 つのテーブルと 1 つの (c) 列を持つ別のテーブルがあり、2 つのテーブルを 3 つの (a、b、c) 列を持つ大きなテーブルに結合したいと考えています。私は単にそれらに参加したいのですが、それらに参加するために条件(Where句)を使用したくありません。しかし、Flink は Where 句を使用するとエラーをスローします。それは、where 句で条件なしでテーブルを結合する方法ですか? where 句を使用したい場合、どのような条件を指定すればよいですか?
以下は、2つのテーブルを結合するための私のコマンドです
正しい方向への助けは大歓迎です。ありがとうございました。
apache-flink - Apache Flink: Spark のような CSV ファイルのスキーマを推測する
Spark では、infer schema を使用して、ファイルからスキーマを動的に読み取ることができます。
Flinkで同じことをする方法はありますか?