最新

Javadoc

用於計算集合中最新元素的轉換和 Combine.CombineFn。

• Latest.globally() 接受值集合，並產生包含具有最新隱含時間戳記的單個值的集合。
• Latest.perKey() 接受鍵值對的集合，並根據隱含時間戳記，傳回每個鍵的最新值。

對於具有相同時間戳記的元素，將任意選取輸出元素。

範例

範例 1：計算每個 Session 的最新值

 PCollection input = ...;
 PCollection sessioned = input
    .apply(Window.into(Sessions.withGapDuration(Duration.standardMinutes(5)));
 PCollection latestValues = sessioned.apply(Latest.globally());

範例 2:

相關轉換

• Reify 在各種 Beam 值的明確和隱含形式之間轉換
• WithTimestamps 將時間戳記指派給集合的所有元素