問題タブ [flink-cep]
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.
scala - flink テーブル SQL API
flink テーブルと SQL API で 2 つのテーブル (結合) を使用してクエリを記述できるかどうかを知りたいです。
私は flik を初めて使用します。2 つの異なるデータ セットから 2 つのテーブルを作成し、それらにクエリを実行して、他のデータセットを生成したいと考えています。
私のクエリは次のようになるselect... from table1, table 2...ので、2つ以上のテーブルをクエリするこのクエリのように書くことができますか?
ありがとう
apache-flink - Flink CEP: さまざまな種類のイベントのデータ ストリームに参加する方法は?
2 つの異なるタイプのデータ ストリームがあり、1 つは気象データを提供し、もう 1 つは車両データを提供し、Flink を使用してデータに対して複雑なイベント処理を行いたいとします。
Flink 1.3.x で使用する正しい方法はどれですか? Union、Connect、Window Join などのさまざまな方法を見ました。基本的には、次のような単純な CEP を試してみたいだけです。
ありがとう！
java - カスタム ソースから flink に継続的にデータを書き込む
Apache Flink (1.3.1) を使用するのは初めてで、質問があります。より詳細には、flink-core、flink-cep、および flink-streaming ライブラリを使用しています。私のアプリケーションは、RabbitMQ からのメッセージを消費する Akka ActorSystem であり、さまざまなアクターがこのメッセージを処理します。StreamExecutionEnvironment一部のアクターでは、Flink からをインスタンス化し、着信メッセージを処理したいと考えています。したがって、クラスを拡張するカスタム ソース クラスを作成しましたRichSourceFunction。Flink 拡張機能にデータを送信する方法がわかりません。これが私のセットアップです：
そして、これは私のカスタムソース関数です:
sendDataそのため、FlinkExtensionクラス内のメソッドを外部から呼び出して、データを連続的に書き込みたいと考えていFlinkExtensionます。これが私のJUnitテストで、データを拡張機能に送信してから、データをに書き込む必要がありSourceContextます。
しかし、テストを実行しても何も起こらず、アプリケーションは の run メソッドでハングしますCustomSourceFunction。CustomSourceFunctionまた、 run メソッドで新しいエンドレス スレッドを作成しようとしました。
要約すると: アプリケーションから Flink インスタンスに継続的にデータを書き込む方法を知っている人はいますか?