Function join

bigflow_python/python/bigflow/schema.py:845–883 · view source on GitHub ↗

对多个输入SchemaPCollection，根据指定的字段(dict)对SchemaPCollection做内连接操作, 连接结果为(fields, (value1, value2, ..., value n)) Args: *pcollection (SchemaPCollection): 输入的多个SchemaPCollection **options: 配置选项，需要配置fields=str/tuple/list(一个列表、元组、一个逗号分隔的字符串，表示指定的字段) Returns: SchemaP

(*pcollections, **options)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers

nothing calls this directly

Calls 7

_check_set_argsFunction · 0.85

_merge_result_after_joinFunction · 0.85

joinMethod · 0.80

_value_serdeFunction · 0.70

getMethod · 0.45

applyMethod · 0.45

serdeMethod · 0.45

Tested by

no test coverage detected