Flinkはタイムウィンドウとプロセスに基づいてメッセージをキャプチャします

Question

私はメッセージを計算し、flinkを使って処理します。ここでフリンクはカフカからデータを読んでいる、私の要件は、私は時間枠の間でデータを読み、処理することです。例えば、 。 12：30 12:00の間

メッセージ、その上

1時まで12時30分の間でメッセージ...と、

は、私はあなたがガイドまたは任意のヘルプを提案することができFLINKに全く新しいですウィンドウイングは、このページで説明されているおかげで

Answer 1

、文書では、この

上：https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/windows.html

具体的には、examplとして（このようになります。 e）：

val windowing: DataStream[(**,**,...)] = data 
    .keyBy(?) 
    .timeWindow(Time.minutes(30)) 
    .map (// your mapping) 
    .reduce (// your reduce function here)