对于给定的PCollection/PTable，聚合为PObject，PObject的内容为list/dict Args: pvalue (PCollection/PTable): 输入 **options: 可配置选项 Returns: PObject: 聚合后的list/dict >>> from bigflow import transforms >>> a = _pipeline.parallelize([1, 1, 2, 3]) >>> transforms.to_pobject
(pvalue, **options)
source not stored for this graph (policy: none)
nothing calls this directly
no test coverage detected