Method map

bigflow_python/python/bigflow/pobject.py:67–82 · view source on GitHub ↗

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

(self, fn, *side_inputs, **options)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 15

_operator_helperMethod · 0.95

mainFunction · 0.45

bayes.pyFile · 0.45

mainFunction · 0.45

group_top_n.pyFile · 0.45

_get_fieldFunction · 0.45

_get_colFunction · 0.45

tuple_to_dictFunction · 0.45

dict_to_tupleFunction · 0.45

selectFunction · 0.45

updateFunction · 0.45

flattenFunction · 0.45

Calls

no outgoing calls

Tested by 15

test_fieldsMethod · 0.36

test_text_fileMethod · 0.36

test_schema_text_fileMethod · 0.36

test_exceptionMethod · 0.36

test_use_lazy_var_in_local_and_transformsMethod · 0.36

test_python_str_serdeMethod · 0.36

test_python_tuple_serdeMethod · 0.36

end_serde_testMethod · 0.36

_apply_funcMethod · 0.36

test_side_inputMethod · 0.36

test_unicode_stringMethod · 0.36

test_lambda_serMethod · 0.36