按键分组

Pydoc

将键控元素集合作为输入，并生成一个集合，其中每个元素都包含一个键以及与该键关联的所有值。

在 Beam 编程指南 中查看更多信息。

示例

示例 1：在以下示例中，我们创建一个管道，其中包含一个按季节键控的 PCollection。

我们使用 GroupByKey 将每个季节的所有农产品分组。

示例 2:

相关转换

• GroupBy 用于按元素的任意属性进行分组。
• CombinePerKey 用于将与某个键关联的所有值组合成单个结果。
• CoGroupByKey 用于多个输入集合。

Pydoc