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