Others

bigflow.util.utils.construct(pipeline, node, type, nested_level=None, inner_most_type=None, key_serdes=None)

Construct a PType from a LogicalPlan node

参数:	pipeline (Pipeline) — the Pipeline constructed PType belongs to node (LogicalPlan.Node) — node type (class) — class of PType to construct

Kwargs:

nested_leve: specify PTable’s nested level if PType is a PTable inner_most_type: specify PTable’s inner-most type if PType is a PTable

返回:	PType
返回类型:	PType

bigflow.util.utils.detect_ptype(runtime_value)

Detect the default PType type for a runtime value

参数:	runtime_value (object) — a runtime value, cannot be PType
返回:	detected PType class
返回类型:	class

bigflow.util.utils.flatten_runtime_value(runtime_value)

Flatten a Python dict to tuple

参数:	runtime_value (object) — value to flatten
返回:	flatten result
返回类型:	object

bigflow.util.utils.is_infinite(obj)

Return if a PType is infinite

参数:	obj (PType) — PType
返回:	True if the PType is infinite, False otherwise
返回类型:	bool

bigflow.util.utils.is_ptype(obj)

Return if an object is a PType

参数:	obj (object) — object
返回:	True if the object is a PType, False otherwise
返回类型:	bool