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

Function group_by

bigflow_python/python/bigflow/transforms.py:422–443  ·  view source on GitHub ↗

利用给定的key_extractor和value_extractor对输入PCollection分组,返回一个表示分组结果的PTable Args: pcollection (PCollection): 输入PCollection key_extractor (function): 用于提取key的函数 value_extractor (function, optional): 用于提取value的函数 **options: 可配置选项 Returns: PTable: 分组结果 >>

(pcollection, key_extractor, value_extractor=None, **options)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 1

group_by_keyFunction · 0.70

Calls 1

group_byMethod · 0.45

Tested by

no test coverage detected