hub / github.com/baidu/bigflow / tuple_to_dict

Function tuple_to_dict

bigflow_python/python/bigflow/schema.py:203–228 · view source on GitHub ↗

从每个元素是tuple的PCollection转化成一个SchemaPCollection。 Args: pcollection (PCollection): 输入PCollection，每个元素是一个tuple fields (list): fields中每个元素是一个tuple(key, value), key是字段名，value是相应字段所用的serde, 若fields中每个元素是一个str表示字段名, 则表示所有类型都是可被marshal序列化的类型 Returns: SchemaPColl

(pcollection, fields)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 1

_ret_dict_handlerFunction · 0.85

Calls 4

_str_to_listFunction · 0.85

appendMethod · 0.80

ofFunction · 0.70

mapMethod · 0.45

Tested by

no test coverage detected