分组批处理

Pydoc

将输入批处理为所需的批处理大小。

示例

在以下示例中，我们创建一个管道，其中包含按季节分类的 PCollection 产品。

我们使用 GroupIntoBatches 为每个键获取固定大小的批次，这将为每个键输出一个元素列表。

相关转换

对于无键数据和动态批处理大小，您可能希望使用 BatchElements。

Pydoc