問題タブ [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.

0 投票する
1 に答える
219 参照

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つのテーブルを結合するための私のコマンドです

正しい方向への助けは大歓迎です。ありがとうございました。

0 投票する
1 に答える
513 参照

apache-flink - Apache Flink: Spark のような CSV ファイルのスキーマを推測する

Spark では、infer schema を使用して、ファイルからスキーマを動的に読み取ることができます。

Flinkで同じことをする方法はありますか?