Method combine

等同于 :func:`bigflow.transforms.combine(self, fn) ` Args: fn (callable): 合并函数 **options: 可配置选项 Returns: PObject: 合并结果 >>> _pipeline.parallelize([2, 4, 6, 10]).combine(sum).get() 22

(self, fn, **options)