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

Function sum

bigflow_python/python/bigflow/transforms.py:935–953  ·  view source on GitHub ↗

对于输入PCollection,求其所有包含元素相加的结果 Args: pcollection (PCollection): 输入PCollection **options: 可配置参数 Returns: PObject: 表示结果的PObject >>> from bigflow import transforms >>> _p = _pipeline.parallelize([1, 2, 3, 4]) >>> transforms.sum(_p).get() 10

(pcollection, **options)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 1

get_sizeMethod · 0.70

Calls 1

sumMethod · 0.80

Tested by

no test coverage detected