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

Function transform

bigflow_python/python/bigflow/transforms.py:986–1109  ·  view source on GitHub ↗

对给定PCollection进行任意的变换,结果为另一个PCollection transform有两种形式,形式一: 基本原型为`transform(pcollection, initializer, transformer, finalizer, *side_inputs, **options)` transform将PCollection的处理分为3个阶段: 初始化,遍历及结束,分别对应于 initializer, transformer和finalizer三个处理函数。三个函数之间有一个状态 status(也可以理解为上下文co

(pcollection, first_arg, *other_args, **options)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 7

applyMethod · 0.70
apply_valuesMethod · 0.70
apply_key_valuesMethod · 0.70
_transform_and_udfMethod · 0.70
EmitMethod · 0.50
recordFunction · 0.50
recordFunction · 0.50

Calls 1

transformMethod · 0.45

Tested by 3

EmitMethod · 0.40
recordFunction · 0.40
recordFunction · 0.40