按键分组
Javadoc获取一个键值元素的集合,并生成一个集合,其中每个元素包含一个键和一个 Iterable
,其中包含与该键关联的所有值。
结果可以与窗口组合,以根据时间或触发器细分每个键,以生成部分聚合。在处理无界集合时,窗口或触发器是必需的。
有关更多信息,请参阅 Beam 编程指南。
示例
相关转换
- CoGroupByKey 用于多个输入集合
- Combine 用于将与一个键关联的所有值组合成一个单一结果
最后更新于 2024/10/31
您是否找到了所有您要找的内容?
它是否有用且清晰?您想更改什么?请告诉我们!