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

Function group_by

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

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

(p, fields)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers

nothing calls this directly

Calls 8

get_serde_of_fieldsFunction · 0.85
joinMethod · 0.80
default_objectorMethod · 0.80
pipelineMethod · 0.80
_select_fieldsFunction · 0.70
splitMethod · 0.45
group_byMethod · 0.45
serdeMethod · 0.45

Tested by

no test coverage detected