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

Function cartesian

bigflow_python/python/bigflow/transforms.py:113–143  ·  view source on GitHub ↗

对多个输入PCollection求笛卡尔积,返回一个PCollection Args: *pcollections: 输入PCollection **options: 可配置选项 Returns: PCollection: 笛卡尔积 >>> from bigflow import transforms >>> p1 = _pipeline.parallelize([1, 2, 3]) >>> p2 = _pipeline.parallelize(['a', 'b', 'c']) >>> tr

(*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

cartesianMethod · 0.45

Tested by

no test coverage detected