返回给定PCollection中元素的数量 Args: pcollection (PCollection): 输入PCollection **options: 可配置选项 Returns: PObject: 元素数量 >>> from bigflow import transforms >>> _p = _pipeline.parallelize([1, 2, 3, 4]) >>> transforms.count(_p).get() 4
(pcollection, **options)
source not stored for this graph (policy: none)