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

Method group_by_key

bigflow_python/python/bigflow/pcollection.py:252–265  ·  view source on GitHub ↗

与 ``group_by`` 变换类似,但使用默认的key/value提取函数对元素分组 Args: **options: 可配置参数 Returns: PTable: 分组结果 >>> _pipeline.parallelize([("A", 4), ("A", 3), ("B", 2), ("A", 1)]).group_by_key().get() {"A": [4, 3, 1], "B": [2]}

(self, **options)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 15

group_top_n.pyFile · 0.80
uv.pyFile · 0.80
count_wordsFunction · 0.80
pagerank_algoFunction · 0.80
test_from_pcollectionMethod · 0.80
test_udfMethod · 0.80
fMethod · 0.80
test_cogroupMethod · 0.80
test_cogroup_optionsMethod · 0.80
test_extract_keyMethod · 0.80
test_extract_valueMethod · 0.80
test_flattenMethod · 0.80

Calls

no outgoing calls

Tested by 13

test_from_pcollectionMethod · 0.64
test_udfMethod · 0.64
fMethod · 0.64
test_cogroupMethod · 0.64
test_cogroup_optionsMethod · 0.64
test_extract_keyMethod · 0.64
test_extract_valueMethod · 0.64
test_flattenMethod · 0.64
test_nested_flattenMethod · 0.64
test_flattenMethod · 0.64
test_nested_flattenMethod · 0.64