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

342 問題
Newest
Active
Bountied
318
Unanswered
0 投票する
1 に答える
91 参照

apache-flink - Apache Flink: ソースから別のデータストリームにパターンを適用する方法は?

イベントのデータストリームと、パターンの別のデータストリームがあります。パターンは実行時にユーザーによって提供され、Kafka トピックを介して取得する必要があります。Flink-CEP を使用して、イベント ストリームに各パターンを適用する必要があります。事前にパターンがわからない場合に DataStream から PatternStream を取得する方法はありますか?

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

apache-flink - 1.4 Apache Flink DataStream に相当する foldLeft 演算子はありますか

私は Apache Flink 1.4 を使用してこのようなストリーム設定をしています

集計操作の出力は AggregateResult オブジェクトであるため、現在終了するストリームは SingleOutputStreamOperator 型です。

次にやりたいことは、scala foldLeft に相当するものです。その機能を提供するオペレーターはありますか。

ありがとう


12345678910