给定一个合并函数,聚合输入PCollection中所有元素,这些元素以迭代器的形式给出 默认情况下,输入类型与输出类型需要一致,假设为O类型,fn的期望签名为 fn([O...]) => O,[]表示输入可遍历 在执行时会把输入pcollection先切分成许多个分片,然后对每个分片的数据组成一个列表,然后调用fn, 将每个分片中的数据合并成一个O类型的变量。 然后,会再将所有分片上生成的那些O类型的值汇聚到一起,组成一个列表,再使用fn最终聚合到一起。 分片的规则用户不应作任何假设。 用户可以显式的指定pre_combine=
(pcollection, fn, **options)
source not stored for this graph (policy: none)