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

Function flatten

bigflow_python/python/bigflow/transforms.py:335–353  ·  view source on GitHub ↗

对于给定PTable中的key和value中每一个元素,构造(key, value)对,结果保存在PCollection中 Args: ptable (PTable): 输入PTable **options: 可配置选项 Returns: PCollection: (key, value)对,结果以PCollection表示 >>> from bigflow import transforms >>> _p = _pipeline.parallelize({"A": [2, 3], "B": [4, 5]

(ptable, **options)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers

nothing calls this directly

Calls 1

flattenMethod · 0.80

Tested by

no test coverage detected