按fields分组。 Args: p (pcollection): 输入数据集,需要是一个每个元素都是dict的pcollection fields(str/[str]): 如果fields为一个str,则会按“,”进行切割,然后按切割出的字段进行分组。 如果fields为一个list,则直接按list中的多个字段进行分组。 Returns: 返回一个key为一个包含指定字段的dict,value为原数据集的PTable。 需要注意的是,由于python
(p, fields)
source not stored for this graph (policy: none)
nothing calls this directly
no test coverage detected