SideInputUtil

A utility to generate LogicalPlan node for SideInputs

class bigflow.util.side_input_util.SideInputsUtil(input, side_input_tuple)

A utility to generate LogicalPlan node for SideInputs

参数:

• input (PType/Node) -- the input to be processed
• side_inputs (tuple) -- a tuple with PType as SideInputs

注解

End-users are not supposed to use this class.

static get_dealt_side_inputs_tuple(side_input_tuple)

get_input()

Get the corresponding node of input

返回:input node 返回类型:LogicalPlan.Node

process_with_side_inputs()

Convert all SideInputs as prepared nodes in LogicalPlan

返回:processed node 返回类型:LogicalPlan.Node