按指定列去重 Args: pcollection (SchemaPCollection): 输入的pcollecton columns (list of str): 要distinct的列 Returns: SchemaPCollection: 做过distinct的pcollection Examples: >>> from bigflow import base, schema, transforms >>> p = base.Pipeline.create('local
(pcollection, columns)
source not stored for this graph (policy: none)
nothing calls this directly
no test coverage detected