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

Method flat_map

bigflow_python/python/bigflow/pobject.py:84–99  ·  view source on GitHub ↗

对包含的元素进行一对多变换,等同于 ``transforms.map(self, fn, *side_inputs, **options)`` Args: fn (function): 变换函数 *side_inputs: 参与运算的SideInputs **options: 可配置选项 Returns: PCollection: 变换结果 >>> _pipeline.parallelize(1).flat_map(lambda x:

(self, fn, *side_inputs, **option)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 15

transform_from_nodeMethod · 0.45
flat_mapFunction · 0.45
count_wordsFunction · 0.45
avg.pyFile · 0.45
test_fieldsMethod · 0.45
flat_map_onFunction · 0.45
to_pcollectionFunction · 0.45
passert_eqFunction · 0.45
test_selectMethod · 0.45
test_aggMethod · 0.45
test_group_byMethod · 0.45

Calls

no outgoing calls

Tested by 15

test_fieldsMethod · 0.36
test_selectMethod · 0.36
test_aggMethod · 0.36
test_group_byMethod · 0.36
test_schemaMethod · 0.36
test_normalMethod · 0.36
test_with_side_inputMethod · 0.36
test_yield_fnMethod · 0.36