Function update

bigflow_python/python/bigflow/schema.py:372–432 · view source on GitHub ↗

用户可以传递一个字典，key表示要修改的字段，value是一个自定义函数用于修改值 update将返回原本SchemaPCollection的所有字段，需要修改的字段更新为新值，不需要修改的字段保留原本的值也可以直接传递一个function表示修改逻辑 Args: pcollection: PCollection(SchemaPCollection) update_fn: Python Dict or or Python Object or Function Returns: pcolle

(pcollection, update_fn, *args)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers

nothing calls this directly

Calls 6

_is_tuple_serdeFunction · 0.85

_is_fieldsdict_serdeFunction · 0.85

wrapper_of_udfFunction · 0.85

selectFunction · 0.70

serdeMethod · 0.45

mapMethod · 0.45

Tested by

no test coverage detected