Function agg

选择一些字段去做一些聚合操作。 Args: p (pcollection): 输入数据集，需要是一个每个元素都是dict的pcollection io_description (str): 格式为： a,b=>c,d,e 即，输入字段=>输出字段 fn (callable) : 函数原型为 (*input_pcollections) => (*output_pcollection_or_pobjects) 即，该函数的输入参数为多个pcollection，

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