元素去重,等同于 :func:`bigflow.transforms.distinct(self) ` Args: **options: 可配置选项 Returns: PCollection: 不重复元素,以PCollection给出 >>> p.parallelize([2, 2, 1, 9, 3, 3]).distinct().get() [2, 3, 1, 9]
(self)
source not stored for this graph (policy: none)
no outgoing calls