最新

Pydoc

获取具有最新时间戳的元素。

示例

在以下示例中，我们创建一个带有 PCollection 的管道，该管道包含农产品以及其收获日期的时间戳。

我们使用 Latest 从 PCollection 中获取具有最新时间戳的元素。

示例 1：全局最新元素

我们使用 Latest.Globally() 获取整个 PCollection 中具有最新时间戳的元素。

示例 2：每个键的最新元素

我们使用 Latest.PerKey() 获取键值 PCollection 中每个键具有最新时间戳的元素。

相关转换

• Sample 随机从集合中获取一些元素。

Pydoc