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

Function select

bigflow_python/python/bigflow/future/fields.py:109–160  ·  view source on GitHub ↗

对每条数据选择一些字段进行变换。 Args: p (pcollection): 输入数据集,需要是一个每个元素都是dict的pcollection io_description (str): 格式为: a,b=>c,d,e 即,输入字段=>输出字段 fn (callable) : 函数原型为 (*input_pobjects) => (*output_pcollection_or_pobjects) 即,该函数的输入参数为多个pobject,每个pobject表示数据的一个字段,

(p, io_description, fn, *args, **kargs)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers

nothing calls this directly

Calls 10

get_out_fields_serdeFunction · 0.85
joinMethod · 0.80
appendMethod · 0.80
default_objectorMethod · 0.80
pipelineMethod · 0.80
apply_valuesMethod · 0.80
flatten_valuesMethod · 0.80
splitMethod · 0.45
group_byMethod · 0.45
serdeMethod · 0.45

Tested by

no test coverage detected