hub / github.com/baidu/bigflow / full_join

Function full_join

bigflow_python/python/bigflow/schema.py:978–1023 · view source on GitHub ↗

对多个输入SchemaPCollection，根据指定的字段(dict)对SchemaPCollection做内连接操作, 连接结果为(fields, (value1, value2, ..., value n)), 若第m个SchemaPCollection没有元素, 则value m为None Args: *pcollection (SchemaPCollection): 输入的多个SchemaPCollection **options: 配置选项，需要配置fields=str/tuple/list(一个列表、元组、一个逗

(*pcollections, **options)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers

nothing calls this directly

Calls 9

_check_set_argsFunction · 0.85

_get_none_dictFunction · 0.85

_none_to_dictFunction · 0.85

_merge_result_after_joinFunction · 0.85

full_joinMethod · 0.80

_value_serdeFunction · 0.70

getMethod · 0.45

applyMethod · 0.45

serdeMethod · 0.45

Tested by

no test coverage detected