计数

Pydoc

计算每个聚合内的元素数量。

示例

在以下示例中，我们创建一个具有两个 PCollection 的产品管道的例子。然后，我们应用 Count 以通过不同的方式获取元素的总数。

示例 1：计算 PCollection 中的所有元素

我们使用 Count.Globally() 来计算 PCollection 中的 所有 元素，即使存在重复元素。

示例 2：为每个键计算元素

我们使用 Count.PerKey() 来计算 PCollection 中每个唯一键的元素。

示例 3：计算所有唯一元素

我们使用 Count.PerElement() 来仅计算 PCollection 中的唯一元素。

相关转换

N/A

Pydoc