hub / github.com/baidu/bigflow / cogroup

Method cogroup

bigflow_python/python/bigflow/pcollection.py:97–110 · view source on GitHub ↗

等同于 :func:`bigflow.transforms.cogroup(self, other, *others) `, Args: other (PCollection): 用于协同分组的PCollection *others: 更多的PCollection Returns: PTable: 分组结果

(self, other, *others)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 14

cogroupFunction · 0.80

white_black_list.pyFile · 0.80

is_unordered_eqFunction · 0.80

test_cogroup_ptableMethod · 0.80

intersectionFunction · 0.80

joinFunction · 0.80

left_joinFunction · 0.80

right_joinFunction · 0.80

full_joinFunction · 0.80

diffFunction · 0.80

subtractFunction · 0.80

Calls

no outgoing calls

Tested by 3

test_cogroup_ptableMethod · 0.64

test_cogroupMethod · 0.64

test_cogroup_optionsMethod · 0.64