hub / github.com/baidu/bigflow / group_by

Function group_by

bigflow_python/python/bigflow/schema.py:494–547 · view source on GitHub ↗

对pcollection按字段group by Args: pcollection (SchemaPCollection): 输入数据集SchemaPCollection(用来表示结构化的，带字段的PCollection), 可以当作每个元素是一个dict的PCollection来用 fields (Iterable): 如果fields为一个str，则会按“,”进行切割，然后按切割出的字段进行分组。如果fields为一个list/tuple，则直接按list中的多个字段进行分组 R

(pcollection, fields, **options)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers

nothing calls this directly

Calls 13

_transform_schema_pcollectionFunction · 0.85

_is_tuple_serdeFunction · 0.85

_origin_serdeFunction · 0.85

_get_serde_of_fieldsFunction · 0.85

apply_valuesMethod · 0.80

joinMethod · 0.80

default_objectorMethod · 0.80

pipelineMethod · 0.80

_select_fieldsFunction · 0.70

serdeMethod · 0.45

group_byMethod · 0.45

ofMethod · 0.45

Tested by

no test coverage detected