hub / github.com/baidu/bigflow / apply_values

Method apply_values

bigflow_python/python/bigflow/ptable.py:183–210 · view source on GitHub ↗

对Value进行一个变换 Args: transform (callable): 作用在Value上的变换函数 *args (object): 变换所需要的参数列表 **options: 可配置选项 Returns: PTable: 变换结果 :: >> nums = _pipeline.parallelize([1, 2, 3]) >> grouped = nums.group_by(

(self, transform, *args, **options)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 15

group_top_n.pyFile · 0.80

selectFunction · 0.80

group_byFunction · 0.80

cogroupFunction · 0.80

distinctFunction · 0.80

_to_pobjectFunction · 0.80

uv.pyFile · 0.80

count_wordsFunction · 0.80

grouped_top_3Function · 0.80

white_black_list.pyFile · 0.80

pagerank_algoFunction · 0.80

selectFunction · 0.80

Calls 5

_broadcastMethod · 0.95

key_serdesMethod · 0.95

PTableClass · 0.85

transformFunction · 0.70

applyMethod · 0.45

Tested by 15

test_fieldsMethod · 0.64

test_commitMethod · 0.64

test_concurrencyMethod · 0.64

test_from_pcollectionMethod · 0.64

test_from_parallelize_and_group_byMethod · 0.64

test_apply_valuesMethod · 0.64

test_apply_values_tupleMethod · 0.64

test_as_pcollectionMethod · 0.64

test_aggMethod · 0.64

test_group_byMethod · 0.64

test_optional_joinMethod · 0.64

test_schemaMethod · 0.64