最新

Javadoc

一种转换和 Combine.CombineFn，用于计算集合中的最新元素。

• Latest.globally() 获取一个值集合，并生成包含具有最新隐式时间戳的单个值的集合。
• Latest.perKey() 获取一个键值对集合，并根据隐式时间戳返回每个键的最新值。

对于具有相同时间戳的元素，输出元素是任意选择的。

示例

示例 1：计算每个会话的最新值

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

示例 2:

相关转换

• 具体化 在各种 Beam 值的显式形式和隐式形式之间进行转换
• WithTimestamps 为集合中的所有元素分配时间戳