取给定PCollection中的任意n个元素。 （如果总元素数量不足n，则返回输入pcollection） Args: pcollection (PCollection): 输入PCollection n (int or PObject): 元素数量 **options: 可配置参数 Returns: PCollection: 表示结果的PCollection >>> from bigflow import transforms >>> _p = _pipeline.parallel
(pcollection, n, **options)
source not stored for this graph (policy: none)