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.

参数:
返回:

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