BroadcastUtil

A utility module containing some helper method for broadcasting mechnism

注解

End-users are not supposed to use the functions.

Author: Wang, Cong(bigflow-opensource@baidu.com)

bigflow.util.broadcast.broadcast_to(pvalue, scope)

Broadcast given PType instance to given scope

参数:

• pvalue (PType) -- PType instance
• scope (LogicalPlan.Scope) -- scope

返回:

new PType after broadcast

返回类型:

PType

bigflow.util.broadcast.is_same_working_scope(v1, v2)

Judge if v1 and v2 works on the same scope. When both of them are PType but their working scopes are different, return False; otherwise returns true.

参数:

• v1 (object) -- object 1
• v2 (object) -- object 2

返回:

if v1 and v2 work on the same scope

返回类型:

bool

bigflow.util.broadcast.working_scope(pvalue)

Returns the working scope of a given PType instance

参数:pvalue (PType) -- PType instance 返回:working scope 返回类型:LogicalPlan.Scope Raises:ValueError -- if invalid argument is given