AfterWatermark.withEarlyFiringsとはどういう意味ですか？

Question

codelabsに記載されている例のwithLateFiringsを理解しています。 withEarlyFiringsはどういう意味ですか？

Answer 1

データフローのウィンドウ処理に関する関連データを読み込むことは価値があります。また、スライディング時間ウィンドウは、データストリーム内の時間間隔を使用してデータのバンドルを定義する。ただし、スライディング時間ウィンドウ処理では、ウィンドウが重なります。各ウィンドウは5分間分のデータをキャプチャすることがありますが、新しいウィンドウは10秒ごとに開始されます。スライディングウィンドウが始まる頻度をピリオドといいます。 詳細は、「Windowing」ドキュメントpage「Sliding Time Windows」のサブセクションから収集することができます。

Answer 2

透かしは、そのウィンドウのすべてのイベントが到着したときのシステムの概念です。早期の発火により、ウォーターマークの前に早期の推測結果が放出されます。

非常に興味深いアニメーションの例はthis articleです。たとえば、次のコードスニペットは、早期のアップデートを毎分提供：

PCollection<KV<String, Integer>> scores = input 
    .apply(Window.into(FixedWindows.of(Duration.standardMinutes(2))) 
       .triggering(
       AtWatermark() 
        .withEarlyFirings(AtPeriod(Duration.standardMinutes(1))) 
        .withLateFirings(AtCount(1)))) 
    .apply(Sum.integersPerKey()); 

あなたはそれで遊んしたい場合にも）getTiming（各火力ペインのタイミングを得ることができます。 PaneInfo docs

@ProcessElement 
public void processElement(ProcessContext c) throws Exception { 
    String timing = c.pane().getTiming().toString()); 
    ... 
}