Method reduce

bigflow_python/python/bigflow/pcollection.py:365–383 · view source on GitHub ↗

使用给定的fn将所有元素规约为单个元素，等同于 :func:`bigflow.transforms.reduce(self, fn, *side_inputs, **options) `, Args: fn (function): 规约函数 *side_inputs: 参与运算的SideInputs **options: 可配置参数 Returns: P

(self, fn, *side_inputs, **options)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 12

reduceFunction · 0.80

test_commitMethod · 0.80

_apply_funcMethod · 0.80

maxFunction · 0.80

minFunction · 0.80

sumFunction · 0.80

test_normalMethod · 0.80

test_side_inputMethod · 0.80

test_reduce_with_side_input_ptableMethod · 0.80

test_modify_left_paramMethod · 0.80

test_streaming_ptable_with_value_pobjectMethod · 0.80

column_sumFunction · 0.80

Calls

no outgoing calls

Tested by 7

test_commitMethod · 0.64

_apply_funcMethod · 0.64

test_normalMethod · 0.64

test_side_inputMethod · 0.64

test_reduce_with_side_input_ptableMethod · 0.64

test_modify_left_paramMethod · 0.64

test_streaming_ptable_with_value_pobjectMethod · 0.64