問題タブ [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.
apache-flink - warnings.print() は、Apache Flink CEP の最初のイベントを除いて、イベントを逆順 (最後のイベントが最初) に出力します
以下のパターンを使用して、Flink で 10 を超えるすべての一時イベントをフィルタリングしようとしています。
入力は、入力関数によってストリームに解析されるテキスト ファイルです。入力ファイルの内容は次のとおりです。
ここで、最初の値は Rack_id で、2 番目の値は温度です
以下に示すように、input-stream と WarnigsStream の両方で print() を発行しました。
ここで、問題が発生します。Flink CEP の出力を以下に示します。
ご覧のとおり、最初の複合イベント (ラック ID = 1 および温度 = 98.0)) は同じ順序で出力されますが、この後、temp > 50 を持つ他のすべての複合イベントは、入力に対して逆の順序で出力されます。ストリーム。
前もって感謝します
maven - Flink-CEP に「Map」のジェネリック型パラメーターがありません
Flink-CEP でパターンを検出するためのコードを以下に示します。
Mac で command + F9 を使用してビルドすると、次のエラーが表示されます
ただし、usignmvn clean installをビルドしてから Control + R で実行すると、出力が表示されます。
なぜこれがいつも起こっているのだろうか？
それを行う方法はありますか？
PS：しかし、私はEclipse JDTプラグインを使用していますが、それでもログにエラーが表示されています。POM.XML の内容は、
提案は大歓迎です。事前に感謝します
serialization - ソケットを使用して Flink で DataStream を送信します。連載問題
VM からホスト マシンにデータのストリームを送信したいのですが、writeToSocket()以下に示す方法を使用しています。
これjoinedStreamEventDataStreamは のタイプDataStream<Integer,Integer>です。
上記のメソッドにシリアライザを渡す方法を教えてください。
前もって感謝します
apache-kafka - VM ソケットから Kafka に DataStream を送信し、ホスト OS の Flink プログラムで受信する: デシリアライゼーションの問題
以下のコードを使用して、VM から Kafka のテスト トピック (ホスト OS で 192.168.0.12 IP で実行) にデータ ストリームを送信しています。
JoinedStreamEvent基本的DataSream<Tuple3<Integer,Integer,Integer>>に2つのストリームに参加respirationRateStreamし、 heartRateStream
ホスト OS で実行されている別の Flink プログラムが kafka からデータ ストリームを読み取ろうとしています。ホスト OS で kafka と Zookeper が実行されているため、ここでは localhost を使用しています。
私はこのような出力を得ています
type のデシリアライザーを実装する必要があると思いますJoinedStreamEvent。JoinedStreamEvent誰かが私にどのように書くべきか、タイプのデシリアライザーを教えてくださいDataSream<Tuple3<Integer, Integer, Integer>>
他に何かする必要がある場合はお知らせください。
PS - 私は次のデシリアライザーを書くことを考えましたが、それは正しくないと思います