flink window apiを使用してストリームウィンドウに1秒あたりの集計関数を適用する方法

Question

関数sumをストリームウィンドウに適用したい場合は、1時間ごとに関数を実行します。
例：
現在のウィンドウは13：00：00-14：59：59で、現在の時刻は13:00:03です。 00：13でsum：00〜13時00分04秒
午前13時00分05秒：00：13でsum 00-午前13時00分05秒

13時00分04秒。
。
。
午前13時59分59秒：00〜午後1時59分59秒

Answer 1

一つの可能​​性は、これがProcessFunctionを使用して、ある実装する：00：sum 13に。この機能を使用すると、たとえば次のようなタイマーを設定できます。毎秒火災。計算の中間結果は、state（たとえば、ListStateまたはValueState）に格納できます。

別の方法は、カスタムTriggerを実装することです。トリガーは、ウィンドウのペインをいつ評価するかを定義します。カスタムエビクターも定義しない限り、コンテンツ自体は影響を受けません。 Hereはトリガーの例です。