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