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

Method flatten

bigflow_python/python/bigflow/ptable.py:254–261  ·  view source on GitHub ↗

对于每个Key和Value中的每个元素(value 1, value 2, ... value m)，构造(Key, value 1), (Key, value 2), ... (Key, value m)，结果使用PCollection表示 Returns: PCollection: 表示结果的PCollection

(self, **option)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 15

group_top_n.pyFile · 0.80
flattenFunction · 0.80
flattenFunction · 0.80
_to_pobjectFunction · 0.80
uv.pyFile · 0.80
count_wordsFunction · 0.80
grouped_top_3Function · 0.80
white_black_list.pyFile · 0.80
pagerank_algoFunction · 0.80
flattenFunction · 0.80
test_commitMethod · 0.80
test_get_nested_cacheMethod · 0.80

Calls

no outgoing calls

Tested by 8

test_commitMethod · 0.64
test_get_nested_cacheMethod · 0.64
test_cogroup_ptableMethod · 0.64
test_udfMethod · 0.64
test_accumulate_sum_with_side_inputs_ptable_apply_valuesMethod · 0.64
test_flattenMethod · 0.64
test_nested_flattenMethod · 0.64
test_cacheMethod · 0.64