分区

Javadoc

将集合中的元素分成多个输出集合。分区函数包含决定如何将输入集合的元素分成每个生成的划分输出集合的逻辑。

分区数量必须在图构建时确定。你不能在管道中间确定分区数量。

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

示例

示例：将 PCollection 分成百分位数组

相关转换

• Filter 如果函数只是决定是否输出元素，则很有用。
• ParDo 是最通用的元素级映射操作，它还包括其他功能，例如多个输出集合和侧输入。
• CoGroupByKey 执行基于键的等值连接。