hub / github.com/baidu/bigflow / apply_key_values

Method apply_key_values

bigflow_python/python/bigflow/ptable.py:212–252 · view source on GitHub ↗

将Key和Value做一个变换 Args: transform (function): 变换函数 *side_inputs: 参与计算的SideInputs **options: 可配置选项 Returns: PTable: 变换结果 :: >> nums = _pipeline.parallelize([1, 2, 3, 4, 5, 6, 7]) >> grouped = nums.g

(self, transform, *side_inputs, **options)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 2

test_cogroup_ptableMethod · 0.80

extract_keysFunction · 0.80

Calls 6

_valueMethod · 0.95

_keyMethod · 0.95

_broadcastMethod · 0.95

key_serdesMethod · 0.95

PTableClass · 0.85

transformFunction · 0.70

Tested by 1

test_cogroup_ptableMethod · 0.64