flink-cep

0熱

1答えて

一度に1つのキーに対して単一のパターンを持つことは可能ですか？例えば、私は、1分のウィンドウ内のどこの条件にマッチする5つのイベントが得られたかどうかをチェックしたいと思います.10分のイベントを分で取得すると、2つのアラートを取得する必要がありますが、6つのアラートが表示されます。すべてのイベントが新しいパターンを引き起こすからです。一度に1つのパターンインスタンスをキーとして使用できますか？

0熱

2答えて

Flinkでカウンタを使用してnumOfRecordsInを取得する

オペレータのnumRecordsInをFlinkに表示したいのですが、これはデータ職人のpptにhereで従っています。カウンターのためのコードは、問題はどのように私はnumber_of_Records_In示ししたいオペレータを指定しないことです public static class mapper extends RichMapFunction<String,String>{ p

0熱

1答えて

Flink CEPのシーケンス一致のセマンティクス

Apache JIRAに問題があります：https://issues.apache.org/jira/browse/FLINK-3703。 after first（つまり、現在の動作です）今後の試合のために、すべてのイベントを保ち続ける - from first：それは、一致シーケンスが発見されたと行動の3種類があります後にマッチングアルゴリズムを継続すべき場所を定義することができます - aft

0熱

3答えて

Flink実行計画UIに表示される演算子、ソース、シンク、パターンの名前付け

オペレータとソースに名前を付けたいだけです。のは、たとえばこれは私がフォームFLINKダッシュボードをとっていることを、実行計画のスクリーンショットであるを見てみましょう。ここで私は2つのDataStreamのソースを持っており、それらに加わっています。私の質問は、これらのソースをEcgStreamとSp02 Streamなどの名前にして、Join1とすることができますか？理由この質問は、視覚

2熱

1答えて

1.4 ApacheのFLINK上foldLeft事業者と同等のは、ウィンドウが、その後</p>が <p>集約演算の出力は集合体であるkeyBy私は、その後でDataStream と、この使用してApache FLINK 1.4 開始のようなストリームを設定しているでDataStream

ありますAggregateResultオブジェクト今終了するストリームはSingleOutputStreamOperator型です私が次に望むのは、scala foldLeftと同じです。その機能を提供する演算子がありますか？おかげ

1熱

1答えて

KeyedStream（Apache Flink）でキーごとにウォーターマークを生成することは可能ですか？

異なる物理デバイスがイベントを送信しているユースケースを実装しようとしています。ネットワーク/電源の問題のために、フリンクソースでイベントを受信するのが遅くなる可能性があります。 Flinkジョブ内の演算子の1つにパターン演算子があります。また、パターンには時間が敏感であるため、イベントの時間特性を使用しています。しかし、特定のデバイスからのイベントに予期せぬ遅延があり、そのイベントが落ちる原因と

0熱

2答えて

FLINKでスーパーサイズのウィンドウを扱うには？

今、私は最後の3ヶ月間に誰かの操作を集約するという要件があります。 MLモデルに結果を入力して異常を取得します。システムの巨大な流れを考慮すると、非常に大きなウィンドウです。このシナリオをどうすれば処理できますか？

0熱

1答えて

Apache Flink：DataStream内のイベントの総数を数える方法

私は2つのrawストリームを持っています。これらのストリームに参加しています。そして、参加したイベントの総数と、ない。 joinedEventDataStream.map(new RichMapFunction<JoinedEvent, Object>() { @Override public Object map(JoinedEvent joinedEvent) t