Function flatten

打平PTable为一个PCollection。如果K,V中有同样的字段，则以value中为准。 Args: p (pcollection): 输入数据集，需要是一个PTable，key,value中都必须为字典。 Returns: 返回一个每个元素是一个dict的pcollection，表示PTable打平后的结果， 如果key,value中有同样字段，以value为准。 例如：:: >>> x = _pipeline.parallelize([{'a': 1, 'b': 2.0, 'c'

(p)