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

Function cogroup

bigflow_python/python/bigflow/transforms.py:146–198  ·  view source on GitHub ↗

对传入的所有pcollection进行协同分组。 cogroup要求所有传入的PCollection的每个元素都是一个(k, v)对, cogroup会用k来作为分组的key,对多个输入PCollection进行协同分组, 返回一个PTable表示分组结果。 这个返回的PTable的每个value为一个tuple,tuple的每个元素是一个PCollection, 其中第n个PCollection表示输入的第n个PCollection在当前key下的全部数据。 如果某个输入PCollection在某个key下无数据,则对应的PCo

(*pcollections, **options)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers

nothing calls this directly

Calls 1

cogroupMethod · 0.80

Tested by

no test coverage detected