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

Method sum

bigflow_python/python/bigflow/pcollection.py:457–470  ·  view source on GitHub ↗

将所有元素相加，等同于 :func:`bigflow.transforms.sum(self) ` Returns: PObject: 相加结果 >>> _pipeline.parallelize([3, 1, 2, 8]).sum().get() 14

(self)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 14

sumFunction · 0.80
avgFunction · 0.80
white_black_list.pyFile · 0.80
test_fieldsMethod · 0.80
test_entity_from_fileMethod · 0.80
test_concurrencyMethod · 0.80
_apply_funcMethod · 0.80
test_100_downstreamMethod · 0.80
test_aggMethod · 0.80
test_group_byMethod · 0.80
test_schemaMethod · 0.80
test_schema_select_after_groupbyMethod · 0.80

Calls

no outgoing calls

Tested by 11

test_fieldsMethod · 0.64
test_entity_from_fileMethod · 0.64
test_concurrencyMethod · 0.64
_apply_funcMethod · 0.64
test_100_downstreamMethod · 0.64
test_aggMethod · 0.64
test_group_byMethod · 0.64
test_schemaMethod · 0.64
test_schema_select_after_groupbyMethod · 0.64
test_schema_complex_case1Method · 0.64
test_udfMethod · 0.64