MCPcopy Create free account
hub / github.com/baidu/bigflow / left_join

Function left_join

bigflow_python/python/bigflow/transforms.py:555–574  ·  view source on GitHub ↗

对于多个输入PCollection,根据key对PCollection做左连接操作 ,连接结果为(key, (value 1, value 2, ..., value n)),若第m个PCollection没有元素, 则value m为None Args: *pcollections: 输入PCollection **options: 可配置选项 Returns: PCollection: 连接结果 >>> x = _pipeline.parallelize([("a", 1), ("b", 4)

(*pcollections, **options)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers

nothing calls this directly

Calls 1

left_joinMethod · 0.80

Tested by

no test coverage detected