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