hub / github.com/baidu/bigflow / cogroup

Function cogroup

bigflow_python/python/bigflow/schema.py:732–771 · view source on GitHub ↗

对多个输入SchemaPCollection进行协同分组，返回一个PTable表示分组结果 PTable的value为所有输入PCollection cogroup会按照输入字段来group到一起 Args: *pcollection (SchemaPCollection): 输入的多个SchemaPCollection **options: 配置选项，需要配置fields=str/tuple/list(一个列表、元组、一个逗号分隔的字符串，表示要group的字段) Returns: PTable:

(*pcollections, **options)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers

nothing calls this directly

Calls 4

_check_set_argsFunction · 0.85

apply_valuesMethod · 0.80

cogroupMethod · 0.80

getMethod · 0.45

Tested by

no test coverage detected