MCPcopy Create free account
hub / github.com/baidu/bigflow / sort

Function sort

bigflow_python/python/bigflow/transforms.py:840–858  ·  view source on GitHub ↗

对于输入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)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 4

combineMethod · 0.50
FlushBufferMethod · 0.50
end_groupMethod · 0.50
TEST_FFunction · 0.50

Calls 1

sortMethod · 0.45

Tested by 1

TEST_FFunction · 0.40