hub / github.com/baidu/bigflow / dict_to_tuple

Function dict_to_tuple

bigflow_python/python/bigflow/schema.py:231–248 · view source on GitHub ↗

从一个SchemaPCollection转化成一个每个元素是tuple的PCollection Args: pcollection (SchemaPCollection): 输入一个SchemaPCollection(FieldsDict) fields (Iterable): 一个列表、元组、一个逗号分隔的字符串，表示要输出的字段 Returns: PCollection: 每个元素是fields对应的值构成的tuple

(pcollection, fields)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers

nothing calls this directly

Calls 6

_str_to_listFunction · 0.85

_transform_schema_pcollectionFunction · 0.85

_is_tuple_serdeFunction · 0.85

_get_tuple_serdeMethod · 0.80

serdeMethod · 0.45

mapMethod · 0.45

Tested by

no test coverage detected