等同于 :func:`bigflow.transforms.cogroup(self, other, *others) <bigflow.transforms.cogroup>`, Args: other (PC

Modified to support __transient__ on new objects Change only affects protocol level 2 (which is always used by PiCloud

inner

对PCollection中的每个元素做一对一映射 对给定的PCollection/PObject中的每个元素应用一个变换函数，以函数的返回结果 构造PCollection/PObject 假设输入类型为I，fn的期望签名为 fn(I) => O Arg

Return the internal node it holds. .. note:: End-users are not supposed to use this function. Returns: LogicalPla

no comments

使用给定的fn将所有元素规约为单个元素， 等同于 :func:`bigflow.transforms.reduce(self, fn, *side_inputs, **options) <bigflow.transforms.redu

Convert all SideInputs as prepared nodes in LogicalPlan Returns: LogicalPlan.Node: processed node

init

等同于 :func:`bigflow.transforms.accumulate(self, zero, accumulate_fn, *side_inputs, **options) <bigflow.transforms.accumulate>`

求当前算子与pvalues的笛卡尔积。 等价于 :func:`bigflow.transforms.cartesian(self, *pvalues, **options) <bigflow.transforms.cartesian>`

inner

Add a single file to be packed with the job at runtime. Args: file_path (str): path of file to add resource_pat

得到表示该Pipeline的唯一ID Returns: int: Pipeline ID

返回Key的序列化/反序列化器

取最大元素，等同于 :func:`bigflow.transforms.max(self, key) <bigflow.transforms.max>` Args: key (function, optional

origin_serde

set load node is infinite

Set cpu limit for this node

Set memory limit for this node

等同于 :func:`bigflow.transforms.transform(self, *args, **options) <bigflow.transforms.transform>`

tricks for enable using expression chain to construct ProcessNode

得到输入PCollection中最大的元素 Args: pcollection (PCollection): 输入PCollection key (function, optional): 用于提取key的函数，与Python内置``max()``中的