对于输入PCollection,将其进行排序 Args: pcollection (PCollection): 输入PCollection reverse (bool): 若True则降序排列,否则为升序排列 Returns: PCollection: 排序结果 >>> from bigflow import transforms >>> _p = _pipeline.parallelize([3, 1, 2, 8]) >>> transforms.sort(_p).get() [1, 2
(pcollection, reverse=False)