/windowApache Flinkチェーンオペレータ

Question

私はWebトラフィック分析のためにApache Flinkを使い始めました。

タイムウィンドウを使用して2つ以上のメトリックを要約する方法が見つかりませんでした。 はfollwing例では、コードは、単語の用法を集約 が、私は言葉を集約する何が必要な場合は、書籍、サイトでは、などの名前を付ける...（ストリーム上の1以上メートル）

val keyValuePair = wordsStream.keyBy(0).timeWindow(Time.seconds(15)) 

Answer 1

私は理解していればストリームのさまざまな属性をグループ化する必要があります。このような場合のために、あなたは簡単なストリーム複製することができます：ストリーム上で複数の操作を呼び出す

val keyValuePair = wordsStream.keyBy(0).timeWindow(Time.seconds(15)) 
val keyValuePair2 = wordsStream.keyBy(1).timeWindow(Time.seconds(15)) 
// and so forth 

を（すなわち、wordsStream）あなたは、同じデータを複数の計算を実行することができます。