对每条数据选择一些字段进行变换。 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 not stored for this graph (policy: none)
nothing calls this directly
no test coverage detected