hub / github.com/baidu/bigflow / accumulate

Method accumulate

bigflow_python/python/bigflow/pcollection.py:43–62 · view source on GitHub ↗

等同于 :func:`bigflow.transforms.accumulate(self, zero, accumulate_fn, *side_inputs, **options) ` Args: zero (value or function): 初始值，或是一个返回初始值的方法 accumulate_fn (function): 聚合方法 *side_inputs: 参与运算的SideInpu

(self, zero, accumulate_fn, *side_inputs, **options)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 9

accumulateFunction · 0.80

atFunction · 0.80

test_output_sortMethod · 0.80

test_accumulate_sumMethod · 0.80

test_accumulate_sum_with_side_inputsMethod · 0.80

test_accumulate_sum_with_side_inputs_ptableMethod · 0.80

fMethod · 0.80

test_accumulate_sum_with_callable_zeroMethod · 0.80

test_sort_strMethod · 0.80

Calls

no outgoing calls

Tested by 7

test_output_sortMethod · 0.64

test_accumulate_sumMethod · 0.64

test_accumulate_sum_with_side_inputsMethod · 0.64

test_accumulate_sum_with_side_inputs_ptableMethod · 0.64

fMethod · 0.64

test_accumulate_sum_with_callable_zeroMethod · 0.64

test_sort_strMethod · 0.64