Function of

bigflow_python/python/bigflow/schema.py:80–94 · view source on GitHub ↗

创建FieldsDictSerde，用来序列化、反序列化有指定字段的字典。因为字段已知，则key无需序列化，序列化出来的数据会小于marshal序列化后的结果。 Args: fields_to_types (dict): 可以传入一个字段名组成的列表，也可以传入一个key是字段名，value是相应字段所用的serde的dict。如果只传入字段名，则表示所有类型都是可被marshal序列化的类型。 Returns: FieldsDictSerde: 相应的序列化器。

(fields_dict)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 8

_get_serde_of_fieldsFunction · 0.70

_get_out_fields_serdeFunction · 0.70

tuple_to_dictFunction · 0.70

selectFunction · 0.70

_merge_serdeFunction · 0.70

_ret_dict_handlerFunction · 0.70

_optional_sdFunction · 0.70

_merge_result_after_joinFunction · 0.70

Calls 1

FieldsDictSerdeClass · 0.70

Tested by

no test coverage detected