hub / github.com/baidu/bigflow / flatten

Function flatten

bigflow_python/python/bigflow/schema.py:550–611 · view source on GitHub ↗

把PTable的所有value拼接上key，并打平成一个SchemaPCollection Args: ptype (PTable): 输入数据集，需要是一个PTable，key,value都必须为字典 Returns: SchemaPCollection: 返回的SchemaPCollection拥有key,value所有的字段，如果key,value中有相同字段，则以value为准 Examples: >>> from bigflow import base, schema >>> p = base.Pi

(ptype)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers

nothing calls this directly

Calls 10

_new_dictFunction · 0.85

_merge_kvFunction · 0.85

_merge_serdeFunction · 0.85

nested_levelMethod · 0.80

flattenMethod · 0.80

key_serdesMethod · 0.80

default_objectorMethod · 0.80

pipelineMethod · 0.80

mapMethod · 0.45

serdeMethod · 0.45

Tested by

no test coverage detected