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

Function map

bigflow_python/python/bigflow/transforms.py:622–649  ·  view source on GitHub ↗

对PCollection中的每个元素做一对一映射 对给定的PCollection/PObject中的每个元素应用一个变换函数,以函数的返回结果 构造PCollection/PObject 假设输入类型为I,fn的期望签名为 fn(I) => O Args: pvalue (PCollection or PObject): 输入P类型 fn (function): 变换函数 *side_inputs: 参与运算的SideInputs **options: 可配置选项 Results:

(pvalue, fn, *side_inputs, **options)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 14

_get_out_fields_serdeFunction · 0.70
__init__Method · 0.70
get_sizeMethod · 0.70
__init__Method · 0.70
__str__Method · 0.70
__init__Method · 0.70
__init__Method · 0.70
__str__Method · 0.70
__init__Method · 0.70
__str__Method · 0.70
sampleFunction · 0.70
originFunction · 0.70

Calls 1

mapMethod · 0.45

Tested by

no test coverage detected