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

Function union

bigflow_python/python/bigflow/transforms.py:1112–1132  ·  view source on GitHub ↗

对于多个输入PCollection/PObject,返回包含它们所有元素的PCollection 输入PCollection必须为同类型 Args: *pvalues: 输入PCollection/PObject Returns: PCollection: 表示结果的PCollection >>> from bigflow import transforms >>> _p1 = _pipeline.parallelize([1, 2, 3, 4]) >>> _p2 = _pipeline.parall

(*pvalues, **options)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers

nothing calls this directly

Calls 1

unionMethod · 0.45

Tested by

no test coverage detected