BroadcastUtil BroadcastUtil A utility module containing some helper method for broadcasting mechnism 注解 End-users are not supposed to use the functions. Author: Wang, Cong(b...

PipelineFactory PipelineFactory 定义用于创建 bigflow.pipeline 的工厂类 class bigflow.base.Pipeline Pipeline是用户一个分布式计算任务的抽象 static create (pipeline_type, **job_config) 根据用户所指定的后...

Others Others Author: panyunhong(bigflow-opensource@baidu.com ) bigflow.util.utils.construct (pipeline, node, type, nested_level=None, inner_most_type=None, key_serdes=None) ...

PType PType Definition of PType . Author: Wang, Cong(bigflow-opensource@baidu.com ) class bigflow.ptype.PType (node, pipeline) 基类：object PType is a basic abstraction of...