返回给定PCollection中所有不重复元素 Args: pcollection (PCollection): 输入PCollection **options: 可配置选项 Returns: PCollection: 不重复元素，以PCollection给出 >>> from bigflow import transforms >>> _p = _pipeline.parallelize([2, 2, 1, 9, 3, 3]) >>> transforms.distinct(_p).get()
(pcollection, **options)
source not stored for this graph (policy: none)