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

Function max_elements

bigflow_python/python/bigflow/transforms.py:736–760  ·  view source on GitHub ↗

得到输入PCollection中前n大的元素 Args: pcollection (PCollection): 输入PCollection n (int/PObject): 必须大于0 key (function, optional): 用于提取key的函数,与Python内置``max()``中的 ``key`` 参数相同 **options: 可配置选项 Returns: PCollection: 包含前n大元素的PCollection,注意对于n=1,这里仍然返回PCollection

(pcollection, n, key=None, **options)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers

nothing calls this directly

Calls 1

max_elementsMethod · 0.80

Tested by

no test coverage detected