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

Function map

bigflow_python/python/bigflow/transform_impls/map.py:26–53  ·  view source on GitHub ↗

Transform map implementation :param pvalue: PType :param fn: UDF :param side_inputs: SideInputs :return:

(pvalue, fn, *side_inputs, **kargs)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 15

cogroupFunction · 0.70
__right_join_in_every_groupFunction · 0.70
left_joinFunction · 0.70
__init__Method · 0.70
unionFunction · 0.70
get_out_fields_serdeFunction · 0.50
common_scopeMethod · 0.50
__init__Method · 0.50
__init__Method · 0.50
set_sizeMethod · 0.50
test_processor_entitiesMethod · 0.50
save_function_tupleMethod · 0.50

Calls 15

process_with_side_inputsMethod · 0.95
default_objectorMethod · 0.80
pipelineMethod · 0.80
get_dealt_side_inputs_tupleMethod · 0.80
set_cpuMethod · 0.80
set_memoryMethod · 0.80
allow_partial_processingMethod · 0.80
ignore_groupMethod · 0.80
set_side_inputsMethod · 0.80
getMethod · 0.45
set_sizeMethod · 0.45
doneMethod · 0.45

Tested by 12

test_processor_entitiesMethod · 0.40
test_use_lazy_var_in_local_and_transformsMethod · 0.40
__init__Method · 0.40
end_serde_testMethod · 0.40
test_broadcastMethod · 0.40
test_takeMethod · 0.40
lookup_dict_and_sumMethod · 0.40
test_simpleMethod · 0.40
test_only_pysMethod · 0.40
test_ignore_hiddensMethod · 0.40
check_parallelizeMethod · 0.40
test_add_remote_file_for_localMethod · 0.40